public static ExecutorService newThreadPoolWithFixedFeed(int poolSize, long keepAliveTime,
      TimeUnit unit, int workQueueSize, String threadName, CommandWrapper commandWrapper,
      PoolStatHelper poolStatHelper, ThreadsMonitoring threadsMonitoring) {
    ArrayBlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(workQueueSize);
    ThreadFactory threadFactory = new LoggingThreadFactory(threadName, commandWrapper);
    return new PooledExecutorWithDMStats(poolSize, keepAliveTime, unit, workQueue, threadFactory,
        poolStatHelper, threadsMonitoring);
  }
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