Delagate thread pool shutdown to Guava MoreExecutors

common/src/main/java/bisq/common/util/Utilities.java

@@ -178,16 +178,9 @@ private static ThreadPoolExecutor getThreadPoolExecutor(String name,
         return executor;
     }
 
-    // TODO: Can some/all of the uses of this be replaced by guava MoreExecutors.shutdownAndAwaitTermination(..)?
     public static void shutdownAndAwaitTermination(ExecutorService executor, long timeout, TimeUnit unit) {
-        executor.shutdown();
-        try {
-            if (!executor.awaitTermination(timeout, unit)) {
-                executor.shutdownNow();
-            }
-        } catch (InterruptedException e) {
-            executor.shutdownNow();
-        }
+        //noinspection UnstableApiUsage
+        MoreExecutors.shutdownAndAwaitTermination(executor, timeout, unit);
     }
 
     public static <V> FutureCallback<V> failureCallback(Consumer<Throwable> errorHandler) {

core/src/main/java/bisq/core/dao/node/full/rpc/BitcoindDaemon.java

@@ -110,8 +110,8 @@ public void shutdown() {
         } catch (IOException e) {
             log.error("Error closing block notification server socket", e);
         } finally {
-            Utilities.shutdownAndAwaitTermination(executor, 1, TimeUnit.SECONDS);
-            Utilities.shutdownAndAwaitTermination(workerPool, 5, TimeUnit.SECONDS);
+            Utilities.shutdownAndAwaitTermination(executor, 2, TimeUnit.SECONDS);
+            Utilities.shutdownAndAwaitTermination(workerPool, 10, TimeUnit.SECONDS);
         }
     }
 

core/src/main/java/bisq/core/provider/price/PriceRequest.java

@@ -78,6 +78,6 @@ public void shutDown() {
         if (provider != null) {
             provider.shutDown();
         }
-        Utilities.shutdownAndAwaitTermination(executorService, 1, TimeUnit.SECONDS);
+        Utilities.shutdownAndAwaitTermination(executorService, 2, TimeUnit.SECONDS);
     }
 }

seednode/src/main/java/bisq/seednode/reporting/SeedNodeReportingService.java

@@ -263,7 +263,7 @@ public void shutDown() {
             dataReportTimer.stop();
         }
 
-        Utilities.shutdownAndAwaitTermination(executor, 2, TimeUnit.SECONDS);
+        Utilities.shutdownAndAwaitTermination(executor, 4, TimeUnit.SECONDS);
     }
 
     private void sendHeartBeat() {