华光ETL同步顺序整合接口 - 如何实现线程安全

华光ETL同步顺序整合接口 - 如何实现线程安全

本文将解释为什么在运行整合华光ETL同步顺序接口 (list 方法) 时，再次调用该方法不会立即返回错误。

该接口使用了 synchronized 关键字对 lock 对象进行同步，这确保了每次只有一个线程能够执行同步代码块 (synchronized(lock) {...})。

工作原理:

1. 当第一个线程调用 list 方法并获得锁时，它会开始执行同步代码块。
2. 如果在第一个线程执行期间，另一个线程再次调用 list 方法，它将被阻塞，因为锁已经被第一个线程持有。
3. 第一个线程执行完毕后，会释放锁，此时被阻塞的第二个线程才能获得锁并执行。

因此，再次调用 list 方法不会立即返回错误，而是需要等待第一个线程执行完毕并释放锁后才能执行。

代码示例:

private static final Object lock = new Object();

/**
 * 整合华光etl同步顺序
 *
 * @return
 */
@AutoLog(value = '整合华光etl同步顺序')
@ApiOperation(value = '整合华光etl同步顺序', notes = '整合华光etl同步顺序')
@GetMapping(value = '/list')
public Result<?> list() throws java.lang.Exception {
    try {
        synchronized(lock) {
            log.info('开始销售订单');
            JSONObject result = odsSalesOrderHeaderService.createSalesOrderToSAP();
            if (result.get('success').equals(false)){
                //发送邮件
                sendMail2(result.getString('message'));
                return Result.error(result.get('message').toString());
            }
        }
    }catch (Exception e){
        return Result.error('接口正在被其他人访问，请稍后再试');
    }
    return Result.ok('同步成功！');
}

总结:

通过使用 synchronized 关键字，我们可以确保 list 方法的线程安全，即使在多个线程同时访问的情况下也能保证数据的一致性。

注意:

• synchronized 代码块会阻塞其他线程，因此在高并发场景下可能导致性能问题。
• 考虑使用更高级的同步机制，例如 ReentrantLock，来提高性能。