执行者：等待特定任务完成

Question

我正在运行的服务器应用程序获取我要使用任务系统处理的多个任务请求。

每个任务都表示为一个可运行的线程池，该线程池中的线程数小于或等于线程池的大小，需要线程池中的线程数。当然，线程池是必要的，以避免CPU因线程过多而过载。

然而，其中一些任务可以是多线程的，而另一些则不能。这就是为什么一个任务可能需要等待其所有特定线程完成，以便合并这些线程的结果以获得最终结果的原因。

如果使用多个Thread实例，则可以像这样加入这些实例：

try {
    // Wait for all threads to finish their tasks
    for (Thread thread : threads) {
        thread.join();
    }
} catch (InterruptedException e) {
    e.printStackTrace();
}

// Finish job here ..

但是我需要这样的东西，使用java.util.concurrent.执行器或任何类似的线程池。

Answer 1

如果我理解正确，你会需要这样的东西（但你的架构似乎太复杂了）：

class MyTask implements Runnable {
    @Override
    public void run() {
        // some work
    }
}

之后：

ExecutorService executorService = Executors.newFixedThreadPool(2000);
ArrayList<Future> futures = new ArrayList<>();

futures.add(executorService.submit(new MyTask()));
futures.add(executorService.submit(new MyTask()));
futures.add(executorService.submit(new MyTask()));

for (Future future: futures) {
    try {
        future.get(100, TimeUnit.SECONDS); 
    } catch (Throwable cause) {
        // process cause
    }
}

每个future.get（）将等待任务结束（本例中最长100秒）。

Answer 2

您可以为每个任务使用ExecutorService和CyclicBarrier，如下所示：

public class ThreadedTask implements Runnable {
    CyclicBarrier barrier;
    public ThreadedTask(CyclicBarrier barrier) {
        this.barrier = barrier;
    }
    @Override
    public void run() {
        // do something
        barrier.await();
    }
}
ExecutorService executor = Executors.newFixedThreadPool(pool_size);
...
CyclicBarrier barrier = new CyclicBarrier(n+1);
for(int i=0; i<n; i++) {
    // launch all tasks
    executor.submit(new ThreadedTask(barrier));
}
// waits for the tasks to finish or timeout
barrier.await(seconds, TimeUnit.SECONDS);