将 Java While 循环转换为多线程循环

Question

我有一个列表说有登录名，基于列表内容，我正在处理其他方法，例如：while ( it.hasNext() ){   method1();}由于这些任务是独立的，我不想等待序列，所以我想并行运行它们。我做了以下操作： ExecutorService service = Executors.newFixedThreadPool(5); final List<Future<?>> futures = new ArrayList<>(); while ( it.hasNext() )    {        Future<?> future = service.submit(() -> {                  method1(it.next());           });        futures.add(future);    }但问题是，它为一个登录名执行 method1 5 次...但我想要 5 个线程独立执行 method1。我哪里做错了？爱！！

Answer 1

您的方法不是线程安全的。
it.hasNext()在每次迭代时调用，因此您可以相信获得了预期结果，但Iterator不是线程安全的。因此，如果同时执行多个Callables，则使用迭代器会产生不可预测的结果。

使用 Thread 或 Callable 当然可以利用并行性，但在使用迭代器时需要添加显式同步。
虽然使用Callable显式同步在某种程度上很烦人。

作为替代方案，您可以使用确保线程安全的集合，例如CopyOnWriteArrayList. 例如，将原始列表包装在CopyOnWriteArrayList复制构造函数中，例如：

List<Foo> copyList = new CopyOnWriteArrayList<>(list);

或者，您也可以更简单地使用并行流，这将使您的代码变得不那么冗长，但它在幕后的线程池的可配置性较低（在某些情况下，这很重要）：

list.parallelStream().forEachOrdered(this::method1);

Answer 2

首先尝试获取迭代值。

final <class> nextItem = it.next();

Future<?> future = service.submit(() -> { method1(nextItem); });

futures.add(future);

Answer 3

我哪里做错了？

你有一个线程正在执行此操作：

while ( it.hasNext() ) {
    Future<?> future = service.submit(...task...);
    futures.add(future);
}

该线程不断调用it.hasNext()，但它从不调用it.next()。

您还有其他线程（线程池的工作线程）在调用，it.next()但这些线程独立于循环运行。如果循环向执行器服务提交任务并将 future 添加到列表所需的时间小于工作线程选择并执行任务所需的时间，则循环将领先于执行器服务，它会提交比您预期更多的任务。