2012-07-07 70 views
2
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做一个下载管理器。这些线程用于分段下载文件。因为,每个细分可能需要不同的时间来下载,我认为这是问题所在。Android:等待线程完成执行方法

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

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

谢谢你的时间。

+2

'上面的代码不告诉我我expected.'什么是预期的结果,什么是你看到的结果吗? – 2012-07-07 12:58:42

+0

什么是不工作的代码?它不会终止吗? – Tudor 2012-07-07 13:15:05

+0

@JohnVint:edited :) – don 2012-07-07 14:00:07

回答

0

如果您需要一组线程,以满足某些点 - 在尝试使用“屏障”的格局。

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

从文档:一个同步辅助类,它允许一组线程都等待对方达成一个共同的障碍点。 CyclicBarriers在涉及固定大小的线程的程序中很有用,它必须偶尔等待对方。该屏障称为循环,因为它可以在等待线程释放之后重新使用。

一个的CyclicBarrier支持每屏障点运行一次,可选的Runnable命令,在党内的最后一个线程到达之后,但任何线程都被释放之前。这种屏障行为对于在任何一方继续之前更新共享状态都很有用。

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