Use native ThreadFactory creator instead of custom one (#783)

JDK21 introduced `Thread.ofPlatform()...factory()` - no need to rely on a custom implementation
pivovarit · Oct 9, 2023 · 04ce124 · 04ce124
1 parent b945f67
commit 04ce124
Showing 1 changed file with 5 additions and 7 deletions.
diff --git a/src/main/java/com/pivovarit/collectors/Dispatcher.java b/src/main/java/com/pivovarit/collectors/Dispatcher.java
@@ -130,13 +130,11 @@ private static Runnable withFinally(Runnable task, Runnable finisher) {
     private static ThreadPoolExecutor newLazySingleThreadExecutor() {
         return new ThreadPoolExecutor(0, 1,
           0L, TimeUnit.MILLISECONDS,
-          new SynchronousQueue<>(),
-          task -> {
-              Thread thread = Executors.defaultThreadFactory().newThread(task);
-              thread.setName("parallel-collector-" + thread.getName());
-              thread.setDaemon(false);
-              return thread;
-          });
+          new LinkedBlockingQueue<>(),
+          Thread.ofPlatform()
+            .name("parallel-collectors-dispatcher-", 0)
+            .daemon(false)
+            .factory());
     }
 
     static final class InterruptibleCompletableFuture<T> extends CompletableFuture<T> {