Выполнение внешней программы с помощью построителя процессов или apaw commons exec

Question

Мне нужно выполнить внешнее приложение, которое возвращает большие данные (требуется более 2 часов для завершения) nand, который непрерывно выводит данные.

Что мне нужно сделать, это выполнить эту программу асинхронно и захватить вывод в файле. Я пробовал использовать java process builder, однако он, кажется, зависает и возвращает выход только тогда, когда программа завершена или принудительно завершена.

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

Затем я прочитал об apache commons exec и попробовал то же самое. Однако это также, кажется, занимает много времени и возвращает различные коды ошибок (для того же входа)

CommandLine cmdLine = new CommandLine("/opt/testsimulator"); 

    DefaultExecuteResultHandler resultHandler = new DefaultExecuteResultHandler(); 
    ByteArrayOutputStream stdout = new ByteArrayOutputStream(); 
    PumpStreamHandler psh = new PumpStreamHandler(stdout); 
    ExecuteWatchdog watchdog = new ExecuteWatchdog(60*1000); 
    Executor executor = new DefaultExecutor(); 
    executor.setStreamHandler(psh); 
    executor.setWatchdog(watchdog); 
    try { 
     executor.execute(cmdLine); 
    } catch (ExecuteException e) { 
     // TODO Auto-generated catch block 
     e.printStackTrace(); 
    } catch (IOException e) { 
     // TODO Auto-generated catch block 
     e.printStackTrace(); 
    } 

Любая помощь или рабочие примеры whould быть очень полезным

Answer 1

Ха. Использование ProcessBuilder должно работать для вашей конфигурации. Например, следующая схема работает для меня:

ProcessBuilder pb = new ProcessBuilder("/tmp/x"); 
Process process = pb.start(); 
final InputStream is = process.getInputStream(); 
// the background thread watches the output from the process 
new Thread(new Runnable() { 
    public void run() { 
     try { 
      BufferedReader reader = 
       new BufferedReader(new InputStreamReader(is)); 
      String line; 
      while ((line = reader.readLine()) != null) { 
       System.out.println(line); 
      } 
     } catch (IOException e) { 
      e.printStackTrace(); 
     } finally { 
      is.close(); 
     } 
    } 
}).start(); 
// the outer thread waits for the process to finish 
process.waitFor(); 

Программа, которую я бегу это просто скрипт с целой кучей sleep 1 и echo линий:

#!/bin/sh 
sleep 1 
echo "Hello" 
sleep 1 
echo "Hello" 
... 

нить чтение из процесс выплескивает Hello каждую секунду или около того.