private void handleRejectedExecutionForBufferConsumer(Runnable r,
        ThreadPoolExecutor executor) {
      logger.warn("An additional " + FUNCTION_EXECUTION_PROCESSOR_THREAD_PREFIX
          + " thread is being launched because all " + executor.getMaximumPoolSize()
          + " thread pool threads are in use for greater than " + OFFER_TIME_MILLIS + " ms");
      launchAdditionalThread(r, executor);
    }
Handle rejected execution for the bufferConsumer (the thread that takes from the blocking
queue and offers to the synchronous queue). Spin off a thread directly in this case,
since an offer has already been made to the synchronous queue and failed. This means that
all the function execution threads are in use.
geode-core/src/main/java/org/apache/geode/distributed/internal/FunctionExecutionPooledExecutor.java