Only one ServerSocket.accept() in parallel !

Issue #504
Riverside-Software · Mar 24, 2023 · 0cfe758 · 0cfe758
1 parent f917425
commit 0cfe758
Showing 1 changed file with 8 additions and 7 deletions.
diff --git a/src/java/com/phenix/pct/PCTBgRun.java b/src/java/com/phenix/pct/PCTBgRun.java
@@ -662,14 +662,15 @@ public int getLocalPort() {
         public void run() {
             ExecutorService group = Executors.newFixedThreadPool(numThreads);
             for (int zz = 0; zz < numThreads; zz++) {
+                final Socket socket;
+                try {
+                    socket = server.accept();
+                } catch (IOException caught) {
+                    setBuildException(caught);
+                    return;
+                }
+
                 group.execute(() -> {
-                    final Socket socket;
-                    try {
-                        socket = server.accept();
-                    } catch (IOException caught) {
-                        setBuildException(caught);
-                        return;
-                    }
                     final BackgroundWorker status = createOpenEdgeWorker(socket);
                     status.setDBConnections(options.getDBConnections().iterator());
                     status.setAliases(options.getAliases().iterator());