java - 如何迭代 Future 对象？

Question

我的call()的返回值方法List<Person> 。 MyCallable 类如下所示:

public class MyCallable implements Callable<List<Person>> {

    public List<Person> call() throws Exception {

           ...
    
           return list;
    }

    public MyCallable(List<Account> accountList) {
        super();
    }
}

下面是我在 CallableFuture 类中编写的代码:

ExecutorService executor = Executors.newFixedThreadPool(NTHREDS);
List<Future<List<Person>>> list = new ArrayList<Future<List<Person>>>();
for (int i = 0; i < 20; i++) {
    Callable<List<Person>> worker = new MyCallable(accountList);
    Future<List<Person>> submit = executor.submit(worker);
    for(Future<List<Person>> :list){
        //list.add(submit);
    }
}

我不知道如何迭代list并添加submit到它。我这样做对吗？

Answer 1

有几个问题。首先，不要在提交每个结果后立即尝试获取 Future 的结果(如果这样做，您实际上只是序列化所有内容并达不到目的)，而是提交 all 其中，然后检索结果:

List<Future<List<Person>>> list = new ArrayList<Future<List<Person>>>();
for (int i = 0; i < 20; i++) {
    Callable<List<Person>> worker = new MyCallable(accountList);
    Future<List<Person>> submit = executor.submit(worker);
    list.add(submit); // just keep track of them
}

// NOW the next step is to get the results...

接下来，您将遇到一些基本的语法问题。一般来说，迭代容器中的项目的语法是:

List<A> list = ...;

for (A a : list) {
   // do things with 'a'
}

最后，您需要检查 Future 的文档，它向您展示了如何等待计算并使用 Future#get() 获取结果。

将所有这些放在一起，您最终会得到下一步(在提交上述所有内容之后):

// ... all tasks submitted and 'list' now contains the Futures, next step:

for (Future<List<Person>> future : list) {
    List<Person> result = future.get(); // wait for task to complete
    // 'result' is now the List<Person> returned from the corresponding callable.
}

提交所有内容然后获取所有结果背后的想法是，您现在允许任务同时执行，而不是等待每个任务完成后再添加下一个任务。然后，最后，即使您最终等待了一些任务，也没关系，因为所有任务的总等待时间已按预期减少。