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();
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()
6508 int waitingThreads; member in AppData6558 waitingThreads(0), in AppData()6749 appData->waitingThreads--; in sslSelect()8413 appData->waitingThreads++; in NativeCrypto_SSL_do_handshake()8659 && appData->waitingThreads > 0) { in sslRead()8666 appData->waitingThreads++; in sslRead()8980 && appData->waitingThreads > 0) { in sslWrite()8987 appData->waitingThreads++; in sslWrite()