public static ExecutorService newThreadPoolWithSynchronousFeedThatHandlesRejection(
      int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, String threadName,
      ThreadInitializer threadInitializer, CommandWrapper commandWrapper) {
    BlockingQueue<Runnable> blockingQueue = new SynchronousQueue<>();
    RejectedExecutionHandler rejectedExecutionHandler =
        new QueuingRejectedExecutionHandler(blockingQueue);
    ThreadFactory threadFactory =
        new LoggingThreadFactory(threadName, threadInitializer, commandWrapper);
    return new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, unit,
        blockingQueue, threadFactory, rejectedExecutionHandler);
  }
Used for P2P Reader Threads in ConnectionTable
geode-core/src/main/java/org/apache/geode/internal/logging/CoreLoggingExecutors.java