public static ExecutorService newThreadPoolWithSynchronousFeed(int corePoolSize,
      int maximumPoolSize, long keepAliveTime, TimeUnit unit, String threadName,
      ThreadInitializer threadInitializer, CommandWrapper commandWrapper) {
    BlockingQueue<Runnable> blockingQueue = new SynchronousQueue<>();
    ThreadFactory threadFactory =
        new LoggingThreadFactory(threadName, threadInitializer, commandWrapper);
    return new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, unit, blockingQueue,
        threadFactory);
  }
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