Java Ожидание завершения всех тем

Question

Редактировать: У меня вопрос другой, он не имеет отношения к связанному вопросу.

У меня есть следующий код с обработчиком завершения.

FutureTask<Void> futureTask = new FutureTask<Void>(() -> { 
    System.out.println("callback"); 
    return null; 
}); 

Runnable task =() -> { 
    for(int i=0; i<5; i++) { 
     System.out.println(Thread.currentThread().getName() + " " + i); 
    } 
    futureTask.run(); 
}; 

new Thread(task).start(); 
new Thread(task).start(); 

В основном я ищу обработчик завершения для переменного количества задач или есть другой подход?

Я вдохновлен этим answer, но кажется, что это часть какой-то библиотеки, в то время как я ищу собственное решение.

Completable Future ???

Вот моя попытка с завершающимися фьючерсами с обработчиком результата в конце.

public void test() { 
    CompletableFuture 
      .supplyAsync(() -> method1()) 
      .supplyAsync(() -> method2()) 
      .supplyAsync(() -> result()); 
} 

public String method1() { 
    System.out.println("calling 1"); 
    return "method1"; 
} 

public String method2() { 
    System.out.println("calling 2"); 
    return "method2"; 
} 

public String result() { 
    System.out.println("result"); 
    return "result"; 
} 

Answer 1

Сохранить ссылки на резьбе, которые вы создали, и вызвать join()

Thread a = new Thread(task); 
Thread b = new Thread(task); 
a.start(); 
b.start(); 

a.join(); 
b.join(); 
//guaranteed that both threads have completed here 

Answer 2

В зависимости от того, сколько контроля вы хотите, вы можете использовать ThreadPoolExecutor:

tpe.execute (Runnable);

Ждать активного счета == 0;

затем выключение исполнителя.

Или сохранить нити в конструкции.

Wait для определенного TTL затем прервать их, если состояние Runnable

Answer 3

Один простой подход, чтобы отправить Runnable (ы) с ExecutorService, а затем вызвать shutdown, затем вызовите awaitTermination:

ExecutorService executor = Executors.newWorkStealingPool(); 
executor.submit(task); 
executor.submit(task); 

executor.shutdown(); 
executor.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS); 

Не нужно использовать CompletableFuture.

Answer 4

Предполагая, что ваш метод result() возвращает значение, которое вы хотите получить, то есть декларируется как Type result(), вы можете использовать

CompletableFuture<Type> f = CompletableFuture.allOf(
    CompletableFuture.runAsync(() -> method1()), 
    CompletableFuture.runAsync(() -> method2()) 
).thenApply(_void -> result()); 

Каждый runAsync создает индивидуальный асинхронный CompletableFuture, который будет завершен один раз Runnable было казнены. Это то же самое, что и supplyAsync, за исключением того, что он не возвращает результат.

allOf создать CompletableFuture, который будет завершен, как только все указанные фьючерсы будут завершены, следовательно, любое зависящее от последовательности действие будет выполняться только после того, как все фьючерсы будут завершены. Используя thenApply, мы создаем зависимое будущее, которое будет завершено с возвращаемым значением result().

Если result() не предназначена для возврата значения, но только действие, которое должно выполняться после все остальные действия были завершены, вы можете использовать

CompletableFuture.allOf(
    CompletableFuture.runAsync(() -> method1()), 
    CompletableFuture.runAsync(() -> method2()) 
).thenRun(() -> result()); 

вместо этого.