【问题标题】:Android: Waiting for the threads to finish executing the methodAndroid:等待线程完成执行该方法
【发布时间】:2012-07-07 16:00:52
【问题描述】:
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;
    }
}

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

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

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

感谢您的宝贵时间。

【问题讨论】:

  • The above code doesn't show me the results I expected. 预期结果是什么?您看到了什么?
  • 代码有什么问题?它不会终止吗?
  • result.get() 的循环应该等待线程终止。它不工作吗?
  • @Tudor:它不会终止,也不会返回一个值。但是当我只是更改代码返回一个我分配的简单int值返回时,它会成功返回。我认为这是因为在 download() 方法中,每种方法可能需要不同的下载时间,因为它使用 HTTPConnections 连接和下载。
  • @user1122359 您已经在等待所有线程完成;这就是shutdown 调用的作用。如果它没有终止,那么至少有一个线程没有终止;这就是你需要解决的问题。我们无法告诉您原因,因为您没有向我们展示该代码。

标签: java android multithreading download wait


【解决方案1】:

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

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

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

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

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

【讨论】:

    猜你喜欢
    • 2014-03-18
    • 1970-01-01
    • 1970-01-01
    • 2015-04-20
    • 1970-01-01
    • 2014-05-10
    • 1970-01-01
    • 2021-08-10
    • 1970-01-01
    相关资源
    最近更新 更多