Java中Do While循环的ExecutorService

Question

我是并发新手，我试图为do-time循环实现执行器服务并发。但是我总是遇到Reject tedExecutionException

以下是我的示例代码：

do {    
    Future<Void> future = executor.submit(new Callable<Void>() {
    @Override        
    public Void call() throws Exception {

        // action
        return null;
    }
    });

    futures.add(future);
    executor.shutdown();

    for (Future<Void> future : futures) {
        try {
            future.get();
        }
        catch (InterruptedException e) {
            throw new IOException(e)
        }          
    } 
}
while (true);

但这似乎是不正确的。我想我在错误的地方调用了关闭。有人能帮我在do-time循环中正确实现执行器服务吗？谢谢。




Answer 1

匿名用户

来自ThreadPoolExecutor文档：

被拒绝的任务

在方法execute（Runnable）中提交的新任务将在执行器关闭时被拒绝，并且当执行器对最大线程和工作队列容量使用有限边界，并且处于饱和状态时也将被拒绝。

在任何一种情况下，执行方法都会调用其Reject tedExecutionHandler的Reject tedExecutionHandler.rejectedExecution（Runnable， ThreadPoolExecitor）方法

从您的代码中可以清楚地看出，您首先调用Shutdown（），然后再提交任务。

另一方面，请参阅此相关SE问题以获取关闭ExecutorService的正确方法：

ExecutorService的关闭（）不会等到所有线程都完成

Answer 2

没错，没有在正确的时间调用shutdown方法。调用关闭后，ExecutorService将不接受任务（除非您实现自己的版本）。

您应该在将所有任务提交给执行程序后调用关闭，因此在这种情况下，在do-time循环之后的某个地方。

Answer 3

ExecutorService.shutdown（）停止ExecutorService接受任何作业。当您完成提交作业时，应该调用它。

也是未来。get（）是一个阻塞方法，这意味着它将阻塞当前线程的执行，除非这个未来（调用get）返回，否则循环的下一次迭代将不会继续。这将在每次迭代中发生，这使得代码非并行。

您可以使用倒计时闩锁等待所有作业返回。

以下是正确的代码。

final List<Object> results = Collections.synchronizedList(new ArrayList<Object>());
final CountDownLatch latch = new CountDownLatch(10);//suppose you'll have 10 futures

do {
    Future<Void> future = executor.submit(new Callable<Void>() {
        @Override
        public Void call() throws Exception {
            // action
            latch.countDown();//decrease the latch count
            results.add(result); // some result
            return null;
        }
    });

    futures.add(future);
} while (true);

executor.shutdown();

latch.await(); //This will block till latch.countDown() has been called 10 times.

//Now results has all the outputs, do what you want with them.

此外，如果您使用的是Java 8，那么您可以看看这个答案https://stackoverflow.com/a/36261808/5343269