fix: Fix race in emulator controller

Author: mutianf

google-cloud-bigtable-emulator-core/src/main/java/com/google/cloud/bigtable/emulator/core/EmulatorController.java

@@ -44,9 +44,12 @@ public class EmulatorController {
 
   private final Path executable;
   private Process process;
+  private Thread stdoutThread;
+  private Thread stderrThread;
   private boolean isStopped = true;
   private Thread shutdownHook;
 
+
   private int port;
 
   public static EmulatorController createFromPath(Path path) {
@@ -127,8 +130,8 @@ public synchronized void start(int port)
         throw e;
       }
     }
-    pipeStreamToLog(process.getInputStream(), Level.INFO);
-    pipeStreamToLog(process.getErrorStream(), Level.WARNING);
+    Thread stdoutThread = pipeStreamToLog(process.getInputStream(), Level.INFO);
+    Thread stderrThread = pipeStreamToLog(process.getErrorStream(), Level.WARNING);
     isStopped = false;
 
     shutdownHook =
@@ -164,6 +167,23 @@ public synchronized void stop() {
     } finally {
       isStopped = true;
       process.destroy();
+
+      try {
+        process.waitFor();
+        if (stdoutThread != null) {
+          stdoutThread.join();
+        }
+        if (stderrThread != null) {
+          stderrThread.join();
+        }
+      } catch (InterruptedException e) {
+        Thread.currentThread().interrupt();
+        LOGGER.log(Level.WARNING, "Interrupted while waiting for emulator to stop", e);
+      } finally {
+        stdoutThread = null;
+        stderrThread = null;
+        process = null;
+      }
     }
   }
 
@@ -239,7 +259,7 @@ private static void waitForPort(int port) throws InterruptedException, TimeoutEx
   }
 
   /** Creates a thread that will pipe an {@link InputStream} to this class' Logger. */
-  private static void pipeStreamToLog(final InputStream stream, final Level level) {
+  private static Thread pipeStreamToLog(final InputStream stream, final Level level) {
     final BufferedReader reader = new BufferedReader(new InputStreamReader(stream));
 
     Thread thread =
@@ -258,6 +278,7 @@ private static void pipeStreamToLog(final InputStream stream, final Level level)
             });
     thread.setDaemon(true);
     thread.start();
+    return thread;
   }
   // </editor-fold>
 }