如何在单个Java Executor服务中识别管道中的所有任务何时完成

Question

我有一个要在文件上完成的任务管道，每种不同类型的任务在不同的执行器服务中运行。在初始化每个executor服务之后，我启动第一个任务，在完成处理所有文件之前，这个任务保证不会完成，因为它处理一个文件夹不需要更多的工作，或者它向Service2提交一个可调用的任务。因此，当第一个任务的shutdown（）调用是必要的时，所有文件都将在task2或pipleline下的另一个任务中处理，依此类推。当我们可以关闭最后一个服务时，我们就完成了。

Loader loader = Loader.getInstanceOf();
List<ExecutorService> services = new ArrayList<ExecutorService>();
ExecutorService es = Executors.newSingleThreadExecutor();

//Init Services
services.add(es);
services.add(task1.getService());
services.add(task2.getService());
services.add(task3.getService());
services.add(task4.getService());

//Start Loading Files
es.submit(loader);

int count = 0;
for (ExecutorService service : services)
{
    service.shutdown();
    count++;
    //Now wait for all submitted tasks to complete, for upto one day per task
    service.awaitTermination(10, TimeUnit.DAYS);
    MainWindow.logger.severe("Shutdown Task:" + count);
}

public class AnalyserService
{
    protected String threadGroup;
    public AnalyserService(String threadGroup)
    {
        this.threadGroup=threadGroup;
    }

    protected  ExecutorService      executorService;
    protected  CompletionService    completionService;

    protected void initExecutorService()
    {
        int workerSize = Runtime.getRuntime().availableProcessors();
        executorService
                = Executors.newFixedThreadPool(workerSize, new SongKongThreadFactory(threadGroup));
    }

    public ExecutorService getService()
    {
        if (executorService == null || executorService.isShutdown())
        {
            initExecutorService();
        }
        return executorService;
    }
}

所以这一切都很好，除了我的cpu加载逻辑不正确。每个服务都使用一个与计算机拥有的CPU数量相等的池。因此，如果计算机有4个CPU，我们有5个服务，那么我们可能有20个线程试图同时工作，使CPU超载。我想在这种情况下，我应该一次只有4个线程。

如果我限制每个服务使用一个线程，那么Id只有5个线程同时运行，但这仍然是正确的，因为

null

Answer 1

问题的核心是：“[...]CPU过载。”如果这是问题所在，只需正确调度应用程序的优先级即可。顺便说一下，您更有可能增加IO负载，而不是增加CPU负载；很多不同的线程实际上是一件好事：-）

但是，您的问题是：“但是，我将如何识别服务何时完成？”非常简单的答案是:submit()而不是invokeAll()并检查您接收的future对象的isdone()方法。

http://docs.oracle.com/javase/1.5.0/docs/api/java/util/concurrent/executorservice.html#submit(java.util.concurrent.callable)