java - 如何在 Java 中并发处理 Collection 中的元素

Question

我需要同时处理某些 Collection 实例中的元素。换句话说，不是迭代 Collection 实例

for (Someclass elem : coll){
     process(elem);
}

我想同时处理这些元素。比如，像 ConcurrentCollectionExecutor(coll, new Callable{...}, numberOfThreads) 这样的东西。此外，应修复多个并发线程。

任何灵活的模式已经存在？

Answer 1

在名为 MyRunnable 的类中将 process 方法设为 run() 方法，该类实现了 Runnable 并且其构造函数将 elem 作为输入并将其存储为实例变量。然后使用:

ExecutorService executor = Executors.newFixedThreadPool(numberOfThreads);
for (Someclass elem : coll){
   Runnable worker = new MyRunnable(elem);
   executor.execute(worker);
}