Searched refs:waitingThreads (Results 1 – 4 of 4) sorted by relevance
73 protected final Queue<WaitingThread> waitingThreads; field in RouteSpecificPool89 this.waitingThreads = new LinkedList<WaitingThread>(); in RouteSpecificPool()123 return (numEntries < 1) && waitingThreads.isEmpty(); in isUnused()268 this.waitingThreads.add(wt); in queueThread()279 return !this.waitingThreads.isEmpty(); in hasThread()289 return this.waitingThreads.peek(); in nextThread()302 this.waitingThreads.remove(wt); in removeThread()
85 protected Queue<WaitingThread> waitingThreads; field in ConnPoolByRoute109 waitingThreads = createWaitingThreadQueue(); in ConnPoolByRoute()343 waitingThreads.add(waitingThread);352 waitingThreads.remove(waitingThread);625 } else if (!waitingThreads.isEmpty()) {629 waitingThread = waitingThreads.remove();687 Iterator<WaitingThread> iwth = waitingThreads.iterator();
284 int waitingThreads() { in testSupplierThreadSafe()285 int waitingThreads = 0; in testSupplierThreadSafe()288 waitingThreads++; in testSupplierThreadSafe()291 return waitingThreads; in testSupplierThreadSafe()299 while (waitingThreads() != numThreads - 1) { in testSupplierThreadSafe()
7389 int waitingThreads; member in AppData7439 waitingThreads(0),7630 appData->waitingThreads--;9413 appData->waitingThreads++;9678 && appData->waitingThreads > 0) {9685 appData->waitingThreads++;10001 && appData->waitingThreads > 0) {10008 appData->waitingThreads++;