ExecutorService中Task对象处理机制及并行写图片问题咨询

核心问题原因 #

你的代码存在两个关键问题：

• 循环变量i的捕获引用问题：Lambda表达式捕获的是变量的引用而非当前值快照，线程池任务真正执行时，循环变量i已经发生变化，可能导致多个任务复用了相同的i值；
• 共享bufferedImage的线程安全问题：所有任务操作同一个BufferedImage实例，主线程在循环中持续修改该对象，线程池的写入任务可能在主线程修改前、修改中或修改后执行，最终只有初始或最终状态的图片被写入。

你的问题解答 #

1. 是否需要同步操作？
   需要，但更合理的方案是避免共享同一个BufferedImage实例。加同步会让主线程修改时等待写入完成，失去并行意义。正确做法是每次循环迭代时，创建当前图片状态的独立副本，让每个任务持有专属副本执行写入。

2. Task进入队列时是否会快照对象状态？
   不会。Lambda中的变量引用是在任务实际执行时才解析取值，而非提交到队列时快照。任务里用到的i和bufferedImage，都是执行线程运行时获取的当前引用值。

修复后的代码示例 #

ExecutorService pool = Executors.newFixedThreadPool(8);
for (int i = array.length - 1; i > 0; i--) {
    // 捕获当前迭代的i值，避免后续修改影响任务执行
    final int currentIndex = i;
    // 创建当前图片的独立副本，每个任务持有专属对象
    BufferedImage imageCopy = new BufferedImage(bufferedImage.getWidth(), bufferedImage.getHeight(), bufferedImage.getType());
    Graphics2D g = imageCopy.createGraphics();
    g.drawImage(bufferedImage, 0, 0, null);
    g.dispose();
    
    pool.execute(() -> {
        try {
            ImageIO.write(imageCopy, "JPG", new File(fileName + currentIndex));
        } catch (IOException e) {
            e.printStackTrace();
        }
    });
    
    // 对原bufferedImage进行操作...
}
// 必须关闭线程池并等待任务完成
pool.shutdown();
try {
    pool.awaitTermination(1, TimeUnit.HOURS);
} catch (InterruptedException e) {
    e.printStackTrace();
}

补充说明 #

• 复制BufferedImage时，上述Graphics2D.drawImage方式可实现基础复制，若需深复制可使用bufferedImage.getSubimage(0, 0, bufferedImage.getWidth(), bufferedImage.getHeight())；
• 显式声明currentIndex捕获当前i值，可彻底避免Lambda引用循环变量导致的取值偏差问题。

内容的提问来源于stack exchange，提问作者Mattia Monari