Исполнитель: Подождите, пока не закончится выполнение определенных задач.

Question

Приложенное серверное приложение получает несколько запросов для задач, которые я хочу обработать, используя систему задач.

Каждая задача представлена ​​в виде Runnable, которая потребует n количество потоков из пула потоков, где n меньше или равно размеру пула потоков. Пул потоков, конечно, необходим для того, чтобы не перегружал процессор слишком большим количеством потоков.

Однако некоторые из этих задач могут быть многопоточными, а некоторые не могут. Поэтому может потребоваться, чтобы одна задача дождалась завершения всех ее конкретных потоков, чтобы объединить результаты этих потоков для конечного результата.

Если один использует несколько 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.Executor или что-нибудь подобное, что работает с пулом потоков.

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);