Java中如何实现多线程

Question

我必须对一个以 1000 个批次运行代码的方法进行多线程处理。我需要将这些批次分配给不同的线程。

目前我已经生成了 3 个线程，但所有 3 个线程都选择了第一批 1000 个线程。 我希望其他批次不应该选择同一批次，而是选择其他批次。

请大家帮忙并提出建议。

Answer 1

我会使用 ExecutorService

int numberOfTasks = ....
int batchSize = 1000;
ExecutorService es = Executors.newFixedThreadPool(3);
for (int i = 0; i < numberOfTasks; i += batchSize) {
    final int start = i;
    final int last = Math.min(i + batchSize, numberOfTasks);
    es.submit(new Runnable() {
        @Override
        public void run() {
            for (int j = start; j < last; j++)
                System.out.println(j); // do something with j
        }
    });
}
es.shutdown();

Answer 2

将批次放入 BlockingQueue并使工作线程从队列中获取批次。

Answer 3

检索批次时使用锁或互斥体。这样，线程就无法同时访问临界区，也不会意外访问同一批。

我假设您在线程选择批次后将其删除。

编辑：aioobe 和 jonas 的答案更好，使用它。这是一个替代方案。 :)

Answer 4

您需要同步对批次中作业列表的访问。 （“同步”本质上意味着“确保线程意识到潜在的竞争条件”。在大多数情况下，这意味着“让某个方法一次由一个线程执行”。）

这是最容易解决的问题，使用 java .util.concurrent 包。查看 的各种实现BlockingQueue 例如 ArrayBlockingQueue 或 LinkedBlockingQueue。