Searched refs:waitingThreads (Results 1 – 9 of 9) 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()
86 … @Override public List<ThreadReference> waitingThreads() throws IncompatibleThreadStateException { in waitingThreads() method in LazyObjectReference87 return getValue().waitingThreads(); in waitingThreads()
108 int waitingThreads; variable238 waitingThreads(0), in AppData()
357 List<ThreadReference> waitingThreads() in waitingThreads() method
530 public List<ThreadReference> waitingThreads() throws IncompatibleThreadStateException { in waitingThreads() method in ObjectReferenceImpl
5943 appData->waitingThreads--; in sslSelect()6042 appData->waitingThreads--; in sslSelect()7761 appData->waitingThreads++; in NativeCrypto_SSL_do_handshake()7937 appData->waitingThreads > 0) { in sslRead()7944 appData->waitingThreads++; in sslRead()8209 appData->waitingThreads > 0) { in sslWrite()8216 appData->waitingThreads++; in sslWrite()
2908 …Deprecated protected java.util.Queue<org.apache.http.impl.conn.tsccm.WaitingThread> waitingThreads;2949 …ated protected final java.util.Queue<org.apache.http.impl.conn.tsccm.WaitingThread> waitingThreads;