From 6ad58ecc7c3c75dc1125d9d9ad1de22eb97ffdde Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Christian=20Kohlschu=CC=88tter?= Date: Mon, 15 Apr 2024 19:55:31 +0200 Subject: [PATCH] common: Rename new method --- .../src/main/java/org/newsclub/net/unix/ThreadUtil.java | 2 +- .../src/main/java20/org/newsclub/net/unix/ThreadUtil.java | 2 +- .../java/org/newsclub/net/unix/domain/MassiveParallelTest.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/junixsocket-common/src/main/java/org/newsclub/net/unix/ThreadUtil.java b/junixsocket-common/src/main/java/org/newsclub/net/unix/ThreadUtil.java index 129050e34..e4837aced 100644 --- a/junixsocket-common/src/main/java/org/newsclub/net/unix/ThreadUtil.java +++ b/junixsocket-common/src/main/java/org/newsclub/net/unix/ThreadUtil.java @@ -58,7 +58,7 @@ public static boolean isVirtualThreadSupported() { * * @return The new executor service. */ - public static ExecutorService newVirtualThreadPerTaskExecutorIfPossible() { + public static ExecutorService newVirtualThreadOrCachedThreadPoolExecutor() { if (isVirtualThreadSupported()) { return Executors.newVirtualThreadPerTaskExecutor(); } else { diff --git a/junixsocket-common/src/main/java20/org/newsclub/net/unix/ThreadUtil.java b/junixsocket-common/src/main/java20/org/newsclub/net/unix/ThreadUtil.java index 38a03cd08..bd3a4c977 100644 --- a/junixsocket-common/src/main/java20/org/newsclub/net/unix/ThreadUtil.java +++ b/junixsocket-common/src/main/java20/org/newsclub/net/unix/ThreadUtil.java @@ -33,7 +33,7 @@ public static boolean isVirtualThreadSupported() { return false; } - public static ExecutorService newVirtualThreadPerTaskExecutorIfPossible() { + public static ExecutorService newVirtualThreadOrCachedThreadPoolExecutor() { return Executors.newCachedThreadPool(); } } diff --git a/junixsocket-common/src/test/java/org/newsclub/net/unix/domain/MassiveParallelTest.java b/junixsocket-common/src/test/java/org/newsclub/net/unix/domain/MassiveParallelTest.java index 1b4fe84ee..95a496e47 100644 --- a/junixsocket-common/src/test/java/org/newsclub/net/unix/domain/MassiveParallelTest.java +++ b/junixsocket-common/src/test/java/org/newsclub/net/unix/domain/MassiveParallelTest.java @@ -62,7 +62,7 @@ public void testAcceptConnect() throws Exception { serverSocket.bind(listenAddr, numServerThreads); ExecutorService esServers = Executors.newFixedThreadPool(numServerThreads); - ExecutorService esClients = ThreadUtil.newVirtualThreadPerTaskExecutorIfPossible(); + ExecutorService esClients = ThreadUtil.newVirtualThreadOrCachedThreadPoolExecutor(); CountDownLatch cl = new CountDownLatch(numConnections);