并行执行任务'n'

Question

我想弄清楚在java中调用一个任务'x'次并且全部并行的最简单的方法。该任务有一个字符串变量，其值对于每次调用都应该是唯一的，并且它返回一个字符串和整型结果。

我一直在网上查找资源，现在我非常困惑。

Answer 1

为了并行执行任务，您的第一个选择应该是ExecutorService。 就像他们在文档说你得到一个实例，就是

ExecutorService service = Executors.newFixedThreadPool(poolSize); 

如果你的任务必须返回一个值，你应该使用

Future<T> submit(Callable<T> task); 

功能。让你的任务实现Callable接口，返回你需要的结果。将您的任务提交给服务，然后通过Future对象等待结果。粗略草图：

public class MyTask implements Callable<StringInt> { 
    public MyTask(String inputParameter) { ... } 
    public StringInt call() { ... } 
} 

... 

List<Future<StringInt>> results = new ArrayList<Future<StringInt>>(); 
ExecutorService service = Executors.newFixedThreadPool(16); 
for (String inputParameter : inputParameters) { 
    // Create tasks and start parallel execution 
    results.add(service.submit(new MyTask(inputParameter))); 
} 

for (Future<StringInt> result : results) { 
    // Wait for tasks to end, and get result 
    StringInt resultValue = result.get(); 
    ... 
}