private static BlockingQueue<Runnable> createWorkQueueWithStatistics(int workQueueSize,
      QueueStatHelper queueStatHelper) {
    BlockingQueue<Runnable> workQueue;
    if (workQueueSize == 0) {
      workQueue = new OverflowQueueWithDMStats<>(queueStatHelper);
    } else {
      workQueue = new OverflowQueueWithDMStats<>(workQueueSize, queueStatHelper);
    }
    return workQueue;
  }
Used for P2P Reader Threads in ConnectionTable
geode-core/src/main/java/org/apache/geode/internal/logging/CoreLoggingExecutors.java