java - Android:WAITING线程完成执行该方法

Question

ExecutorService exec = Executors.newFixedThreadPool(8);
List<Future<Object>> results = new ArrayList<Future<Object>>();

// submit tasks
for(int i = 0; i < 8; i++) {
    results.add(exec.submit(new ThreadTask()));
}

...

// stop the pool from accepting new tasks
exec.shutdown();

// wait for results
for(Future<Object> result: results) {
    Object obj = result.get();
}


class ThreadTask implements Callable<Object> {

    public Object call() {
        // execute download
        ...
        return result;
    }
}

上面的代码没有显示我预期的结果。更详细地说，我正在为安卓做一个下载管理器。这些线程用于分段下载文件。因为，每个段可能需要不同的持续时间来下载，我认为这就是问题所在。

然后我尝试在方法中使用简单的数字返回。然后线程开始给出预期的结果。

因此，作为一种解决方案，我想到了实现一种等待所有线程完成执行的方法。在上面的代码中，如何等待所有线程完成它们的工作？。我想我必须使用 wait() 方法，但我不知道该怎么做。希望你能帮助解决这个问题。

感谢您的宝贵时间。

Answer 1

如果您需要一组线程在某个时间点相遇 - 尝试使用“屏障”模式。

Java SE 有它的实现:java.util.concurrent.CyclicBarrier

来自文档:一种同步辅助工具，允许一组线程全部等待彼此到达一个共同的障碍点。 CyclicBarriers 在涉及必须偶尔相互等待的固定大小线程组的程序中很有用。屏障之所以称为循环屏障，是因为它可以在等待线程被释放后重新使用。

CyclicBarrier 支持可选的 Runnable 命令，该命令在每个障碍点运行一次，在派对中的最后一个线程到达之后，但在释放任何线程之前。此屏障操作对于在任何一方继续之前更新共享状态很有用。

http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/CyclicBarrier.html