のJava：スレッドでの処理を開始し、作成したプロセス

Question

への参照を取得し、私はテストを実行する前に、私は様々なサービスを開始し、次の統合テストコードを持っている：

@BeforeClass 
public static void setup() throws Exception { 

    // Set some vars like javaBin location 

    ProcessBuilder builder = new ProcessBuilder(javaBin, "-jar", "app.jar"); 
    Process process = launchProcess(builder); 

} 

private static Process launchProcess(ProcessBuilder builder) throws IOException { 

    AtomicReference<Process> process = new AtomicReference<>(); 
    new Thread(() -> { 
    try { 
     process.set(builder.start()); 

     BufferedReader processStd = new BufferedReader(new InputStreamReader(process.get().getInputStream());  
     BufferedReader processErr = new BufferedReader(new InputStreamReader(process.get().getErrorStream())); 

     // To prevent deadlocks due to limited buffer size 
     String s = ""; 
     while(processStd .readLine() != null) {} 
     while((s = processErr .readLine()) != null) { 
      System.err.println(s); 
     } 
    } 
    catch (IOException e) { 
     e.printStackTrace(); 
    } 
    }).start(); 

    return process.get(); 
} 

プロセスはOK開始しますが、 I process.get()は常にnullを返します。私は間違って何をしていますか？上記の方法を使用して、開始したプロセスへの参照を取得するにはどうすればよいですか？ setup()関数内にプロセスを設定した場合、すなわちprocess = builder.start()の場合、正しく動作します。しかし、それは別のJVMで数多くの別々のサービスを開始する必要があるので、多くの繰り返しにつながります。

Answer 1

launchProcessの末尾にprocess.get()と返されるまでにスレッドが実際に開始していない可能性が最も高いです。

実際にスレッドが起動し、メソッドから戻る前にprocess.set(builder.start())への呼び出しを実行するまで待つ必要があります。

これはCountDownLatchのような単純なもので行うことができます。

private static Process launchProcess(ProcessBuilder builder) throws IOException { 
    final CountDownLatch latch = new CountDownLatch(1); 
    // ... 
    new Thread(() -> { 
    try { 
     process.set(builder.start()); 
     latch.countDown(); 
     //... 
    } catch (IOException e) { 
     //... 
    } 
    }).start(); 

    latch.await(); 
    return process.get(); 
}