Java, подождите, пока дочерний процесс завершится

Question

Использование Java ProcessBuilder Я создаю группу дочерних процессов. Я могу использовать метод waitFor() из результирующего объекта Process, чтобы дождаться выхода этого конкретного ребенка.

Можно ли заблокировать до какой-либо ребенок выходит в порядке системного вызова UNIX wait()?

Answer 1

пользователя о CountDownLatch

A CountDownLatch инициализируется с данного графа. Методы Await блокировать , пока текущее значение счетчика не достигнет нулевого из-за вызовами CountDown() метод, после чего все ожидающие потоки будут освобождены и любые последующие вызовы ждут возвращения немедленно. Это одноразовый феномен - количество не может быть сброс. Если вам нужна версия, которую сбрасывает счет, подумайте об использовании CyclicBarrier.

Answer 2

Для достижения этой цели вам необходимо использовать некоторую форму IPC. Если вам разрешено использовать собственные библиотеки, и если вы работаете на платформе UNIX/Linux, попробуйте использовать тот же системный вызов wait(), написав простую обертку JNI &, вызывающую собственный метод из java-кода.

Если вы не можете использовать собственные механизмы IPC, используйте механизм TCP/IP server/client, в котором вы контролируете выход дочернего процесса с сервера, когда клиент подключается/отключается от сервера. Когда нет дочерних подключений, вы можете выйти из программы сервера!

Answer 3

Первый шаг, чтобы представить работу каждого подпроцесса как Future, например, так:

final ProcessBuilder builder = ...; 

// for each process you're going to launch 
FutureTask task = new FutureTask(new Callable<Integer>() { 
    @Override public Integer call() { 
    return builder.start().waitFor(); 
    } 
}; 

Теперь представить все задачи исполнителя:

ExecutorService executor = Executors.newCachedThreadPool(); 
for (FutureTask task : tasks) { 
    executor.submit(task); 
} 

// no more tasks are going to be submitted, this will let the executor clean up its threads 
executor.shutdown(); 

Теперь использовать отличную ExecutorCompletionService класс:

ExecutorCompletionService service = new ExecutorCompletionService(executor); 
while (!executor.isTerminated()) { 
    Future<Integer> finishedFuture = service.take(); 
    System.out.println("Finishing process returned " + finishedFuture.get()); 
} 

Этот цикл будет повторяться один раз накануне когда он заканчивается. returnValue будет кодом выхода дочернего процесса.

Теперь вы точно не знаете, какой процесс завершился. Вы можете изменить Callable вместо того, чтобы возвращать Integer, чтобы просто вернуть Process или даже лучше ваш собственный класс, представляющий результат процесса.

О, и, конечно, если вы не заботитесь о ожидании всех задач, вы можете просто позвонить take() один раз.