Apache CommonsExec асинхронный вызов, предотвращающий вызов синхронизации

Question

У меня есть два вызова, которые я выполняю с помощью CommonsExec - один из них - стандартный синхронный вызов, в котором я вызываю пакетный файл для компиляции проекта maven, а следующий - асинхронный вызов также для пакета файл, который запускает скомпилированный проект командной строки.

Пакетные файлы Maven выглядеть

call mvn package 

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

Это работает отлично в первый раз, но второй вызов сборки синхронизации по какой-то причине не возвращается, хотя выведенный в журнал вывод показывает, что сборка завершена успешно. Программа, очевидно, не запускается.

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

Может кто поможет здесь?

Код для вышеперечисленного

private static final String LAUNCH_CLIENT_FORMAT = "\"%s\\start.bat\" http://localhost:%d" + ENDPOINT; 
private static final String COMPILE_FORMAT = "\"%s\\compile.bat\""; 

private static boolean compileAndLaunch(String aiDirectory, int port) { 
    System.out.println("Compiling " + aiDirectory + " for port " + port); 
    if (!run(String.format(COMPILE_FORMAT, aiDirectory), aiDirectory)) 
    return false; 

    System.out.println("Done compiling " + aiDirectory + " for port " + port + ", launching..."); 
    if (!runAsync(String.format(LAUNCH_CLIENT_FORMAT, aiDirectory, port), aiDirectory)) 
    return false; 

    return true; 
} 

private static boolean run(String command, String directory) { 
    DefaultExecutor executor = getExecutor(directory); 
    System.out.println("Running " + command); 
    CommandLine commandLine = CommandLine.parse(command); 
    try { 
    executor.execute(commandLine); 
    } 
    catch (ExecuteException e) { 
    System.out.println("Failed to execute " + command); 
    return false; 
    } 
    catch (IOException e) { 
    System.out.println("IO Exception running " + command); 
    return false; 
    } 
    return true; 
} 

private static DefaultExecutor getExecutor(String directory) { 
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream(); 
    PumpStreamHandler streamHandler = new PumpStreamHandler(outputStream); 
    DefaultExecutor executor = new DefaultExecutor(); 
    executor.setWorkingDirectory(new File(directory)); 
    executor.setStreamHandler(streamHandler); 
    return executor; 
} 

private static boolean runAsync(String command, String directory) { 

    CommandLine commandLine = CommandLine.parse(command); 
    System.out.println("Running async " + command); 
    DefaultExecutor executor = getExecutor(directory); 
    DefaultExecuteResultHandler resultHandler = new DefaultExecuteResultHandler(); 
    try { 
    executor.execute(commandLine, resultHandler); 
    } 
    catch (ExecuteException e) { 
    System.out.println("Failed to execute " + command); 
    return false; 
    } 
    catch (IOException e) { 
    System.out.println("IO Exception running " + command); 
    return false; 
    } 
    return true; 
} 

Answer 1

Это ваш обратный вызов:

DefaultExecuteResultHandler resultHandler = new DefaultExecuteResultHandler(); 

Это ваш асинхронный исполнитель:

executor.execute(commandLine, resultHandler); 

Но, в асинхронном режиме, сразу после вызов executor.execute() метод будет продолжаться, но пока что-то не произойдет в другом потоке и resultHandler.onProcessComplete() или resultHandler.onProcessFailed(), вы все еще не знаете, закончилось ли выполнение, и не следует выходить из метода runAsync().

Я считаю, что изменить способ к чему-то, как это будет работать:

private static boolean runAsync(String command, String directory) { 

    CommandLine commandLine = CommandLine.parse(command); 
    System.out.println("Running async " + command); 
    DefaultExecutor executor = getExecutor(directory); 
    DefaultExecuteResultHandler resultHandler = new DefaultExecuteResultHandler(); 
    try { 
    executor.execute(commandLine, resultHandler); 
    resultHandler.waitFor(); 
    if(resultHandler.getException() != null){ 
     throw resultHandler.getException(); 
    } 
    } 
    catch (ExecuteException e) { 
    System.out.println("Failed to execute " + command); 
    return false; 
    } 
    catch (IOException e) { 
    System.out.println("IO Exception running " + command); 
    return false; 
    } 
    return true; 
} 

Поскольку resultHandler.waitFor() заставит ждать нить, пока не закончится выполнение.

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