您遇到的多线程问题源于对共享变量 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 { 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 值被增加之前,只有单个线程能访问它。这将保证您的业务逻辑按顺序处理,并且不会出现重复。
© 版权声明
文章版权归作者所有,未经允许请勿转载。
【小浪云服务商 - 服务器12元起 - 挂机宝5元起】
THE END
暂无评论内容