public static ExecutorService newWorkStealingPool(String threadName, int maximumParallelThreads) {
    ForkJoinWorkerThreadFactory factory = pool -> {
      ForkJoinWorkerThread worker = defaultForkJoinWorkerThreadFactory.newThread(pool);
      LoggingUncaughtExceptionHandler.setOnThread(worker);
      worker.setName(threadName + worker.getPoolIndex());
      return worker;
    };
    return new ForkJoinPool(maximumParallelThreads, factory, null, true);
  }
Used for P2P Reader Threads in ConnectionTable
geode-logging/src/main/java/org/apache/geode/logging/internal/executors/LoggingExecutors.java