public static ExecutorService newThreadPoolWithUnlimitedFeed(int poolSize, long keepAliveTime,
      TimeUnit unit, String threadName, ThreadInitializer threadInitializer,
      CommandWrapper commandWrapper, PoolStatHelper poolStatHelper,
      ThreadsMonitoring threadsMonitoring) {
    LinkedBlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>();
    ThreadFactory threadFactory =
        new LoggingThreadFactory(threadName, threadInitializer, commandWrapper);
    return new PooledExecutorWithDMStats(poolSize, keepAliveTime, unit, workQueue, threadFactory,
        poolStatHelper, threadsMonitoring);
  }
Used for P2P Reader Threads in ConnectionTable
geode-core/src/main/java/org/apache/geode/internal/logging/CoreLoggingExecutors.java