Searched refs:waitingThreads (Results 1 – 3 of 3) sorted by relevance
68 protected final Queue<WaitingThread> waitingThreads; field in RouteSpecificPool84 this.waitingThreads = new LinkedList<WaitingThread>(); in RouteSpecificPool()118 return (numEntries < 1) && waitingThreads.isEmpty(); in isUnused()263 this.waitingThreads.add(wt); in queueThread()274 return !this.waitingThreads.isEmpty(); in hasThread()284 return this.waitingThreads.peek(); in nextThread()297 this.waitingThreads.remove(wt); in removeThread()
80 protected Queue<WaitingThread> waitingThreads; field in ConnPoolByRoute104 waitingThreads = createWaitingThreadQueue(); in ConnPoolByRoute()338 waitingThreads.add(waitingThread);347 waitingThreads.remove(waitingThread);620 } else if (!waitingThreads.isEmpty()) {624 waitingThread = waitingThreads.remove();682 Iterator<WaitingThread> iwth = waitingThreads.iterator();
283 int waitingThreads() { in testSupplierThreadSafe()284 int waitingThreads = 0; in testSupplierThreadSafe()287 waitingThreads++; in testSupplierThreadSafe()290 return waitingThreads; in testSupplierThreadSafe()298 while (waitingThreads() != numThreads - 1) { in testSupplierThreadSafe()