java 多线程同步疑问进阶
您遇到的多线程问题源于对共享变量 lt_num2 缺乏同步。
在您的代码中，num() 方法是分配给多线程处理的业务逻辑。在 main 方法中，您在循环中调用 num() 方法时漏掉了对 lt_num2 的同步。
当第一个线程调用 num(lt_num2) 时，它可能会发现 lt_num2 已被其他线程增加。例如，在 lt_num2=i 之前加锁，可以防止出现这种情况。
立即学习“Java免费学习笔记（深入）”；
以下是如何实现同步的：
public class ThreadExample {
// 使用 ReentrantLock 锁机制
private static ReentrantLock lock = new ReentrantLock();
public static void main(String[] args) {
int lt_num2 = 1;
// 创建一个线程池，线程数与您要处理的业务逻辑数量相同
ExecutorService executorService = Executors.newFixedThreadPool(20);
// 遍历需要处理的业务逻辑
for (int i = 1; i <= 20; i++) {
executorService.submit(() -> {
lock.lock();
try {
// 同步代码块
num(lt_num2);
lt_num2++;
} finally {
lock.unlock();
}
});
}
executorService.shutdown();
executorService.awaitTermination(1, TimeUnit.MINUTES);
}
private static void num(int num) {
// 业务处理逻辑
System.out.println("当前处理数字：" + num);
}
}通过在 lt_num2=i 之前加锁，您可以确保在 lt_num2 值被增加之前，只有单个线程能访问它。这将保证您的业务逻辑按顺序处理，并且不会出现重复。
