123   private LinkedBlockingQueue<Operation> opQueue;
179         opQueue = new LinkedBlockingQueue<>(maxCapacity);
185         opQueue = new LinkedBlockingQueue<>();
241     opQueue.removeAll(pendingOperations);
358           while (!opQueue.offer(operation, 1, TimeUnit.SECONDS))
385         if (!opQueue.offer(operation))
467         Operation nextOperation = opQueue.poll(5, TimeUnit.SECONDS);
627       return opQueue.size();
716         oldOpQueue = opQueue;
717         opQueue = newOpQueue;
737           opQueue.put(pendingOperation);
775       if (!opQueue.isEmpty())

Indexes created Tue Jul 24 14:28:13 CEST 2018