core/src/main/java/org/infinispan/executors/LimitedExecutor.java
/**
    * When stopping, cancel any queued tasks.
    */
When stopping, cancel any queued tasks.
When stopping cancel any queued tasks .
public void cancelQueuedTasks() {
      lock.lock();
      try {
         queue.clear();
      } finally {
         lock.unlock();
      }
   }
public void cancelQueuedTasks ( ) { lock . lock ( ) ; try { queue . clear ( ) ; } finally { lock . unlock ( ) ; } }
When stopping, cancel any queued tasks.
When stopping cancel any queued tasks .