improve process logging

Author: tomix26

src/main/java/io/zonky/test/db/postgres/embedded/EmbeddedPostgres.java

@@ -252,7 +252,7 @@ private void startPostmaster(Map<String, String> connectConfig) throws IOExcepti
         final Process postmaster = builder.start();
 
         if (outputRedirector.type() == ProcessBuilder.Redirect.Type.PIPE) {
-            ProcessOutputLogger.logOutput(LOG, postmaster);
+            ProcessOutputLogger.logOutput(LOG, postmaster, "pg_ctl");
         }
 
         LOG.info("{} postmaster started as {} on port {}.  Waiting up to {} for server startup to finish.", instanceId, postmaster.toString(), port, pgStartupWait);
@@ -583,7 +583,8 @@ private void system(String... command)
             final Process process = builder.start();
 
             if (outputRedirector.type() == ProcessBuilder.Redirect.Type.PIPE) {
-                ProcessOutputLogger.logOutput(LOG, process);
+                String processName = command[0].replaceAll("^.*[\\\\/](\\w+)(\\.exe)?$", "$1");
+                ProcessOutputLogger.logOutput(LOG, process, processName);
             }
             if (0 != process.waitFor()) {
                 throw new IllegalStateException(String.format("Process %s failed%n%s", Arrays.asList(command), IOUtils.toString(process.getErrorStream())));

src/main/java/io/zonky/test/db/postgres/embedded/ProcessOutputLogger.java

@@ -13,12 +13,14 @@
  */
 package io.zonky.test.db.postgres.embedded;
 
+import org.slf4j.Logger;
+
 import java.io.BufferedReader;
 import java.io.IOException;
 import java.io.InputStreamReader;
 import java.nio.charset.StandardCharsets;
 
-import org.slf4j.Logger;
+import static org.apache.commons.lang3.StringUtils.isNotBlank;
 
 /**
  * Read standard output of process and write lines to given {@link Logger} as INFO;
@@ -61,9 +63,10 @@ public void run() {
         }
     }
 
-    static void logOutput(final Logger logger, final Process process) {
+    static void logOutput(final Logger logger, final Process process, final String processName) {
+        final String threadName = isNotBlank(processName) ? processName + "@" + process.hashCode() : process.toString();
         final Thread t = new Thread(new ProcessOutputLogger(logger, process));
-        t.setName("output redirector for " + process);
+        t.setName(threadName);
         t.start();
     }
 }