private void logDebug(final ExecutionContext executionContext, final String message) {
    final Thread queryThread = Thread.currentThread();
    logger.debug(
        message + " QueryMonitor size is: {}, Thread (id): {}, Query: {}, Thread is : {}",
        executor.getQueue().size(), queryThread.getId(),
        executionContext.getQuery().getQueryString(),
        queryThread);
  }
Run all cancelation tasks. Leave the executor's task queue empty.
geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryMonitor.java