public static ExecutorService newThreadPoolWithSynchronousFeed(int poolSize, long keepAliveTime,
      TimeUnit unit, String threadName, RejectedExecutionHandler rejectionHandler,
      PoolStatHelper poolStatHelper) {
    SynchronousQueue<Runnable> workQueue = new SynchronousQueue<>();
    ThreadFactory threadFactory = new LoggingThreadFactory(threadName);
    return new PooledExecutorWithDMStats(poolSize, keepAliveTime, unit, workQueue, threadFactory,
        rejectionHandler, poolStatHelper, null);
  }
Utility class that creates instances of ExecutorService whose threads will always log uncaught
exceptions.
geode-core/src/main/java/org/apache/geode/internal/logging/CoreLoggingExecutors.java