如何在并发java编程中指定线程执行？

Question

我使用Callable、Executor和Future对象从不同的线程并行调用and服务。在执行完所有的webservice调用之后，我在jsp中显示结果。

这里我有一个疑问:如果其中一个jsp服务调用失败，我如何在jsp中显示成功调用的结果？

如果一个线程在这种情况下需要更多的时间来执行，我想跳过该响应，并在jsp中显示其余的结果。

我试图在一个webserice中添加一个Thread.sleep(1000)，但是在jsp中响应也被延迟了。

Answer 1

如果您使用的是executor服务，则可以在提交完所有可调用后使用超时终止它：

executor.shutdown();
boolean terminated = executor.awaitTermination(1, TimeUnit.SECONDS);

如果您已经存储了提交作业时由executor返回的期货，则可以遍历列表并检查哪个任务尚未完成：

if (!terminated) {
    for (Future f : futureList) {
        if (!f.isDone()) { System.out.println("This task " + f + " did not complete"); }
    }
}

Answer 2

您可能希望在启动所有其他线程的主线程中考虑CountdownLatch。

这个想法是，在你产生所有线程之后，你开始在给定的超时时间内等待锁存器。每个线程在完成时都必须调用锁存器上的countDown()方法。因此，当所有线程完成或超时时，主线程将继续运行。

Answer 3

有人发布了这篇文章并删除了他的答案，但我认为这可能会有所帮助。

您可以使用ExecutorCompletionService

当您准备好在ExecutorService上呈现poll时，您可以简单地提交到ExecutorService。它将为您提供最近完成的未来，或者坐在那里等待，直到其中一个准备就绪。

ExecutorCompletionService e = new ExecutorCompletionService(...);

for(int i =0; i < n ; i++)
    e.submit(..);

当你准备好的时候

for(int i =0 ; i < n; i++){
   T t = e.poll(); //or with a timeout: T t = e.poll(100, TimeUnit.MILLISECONDS); 
   //do rendering
}

应该考虑到你的用例。