Searched refs:waiter (Results 1 – 4 of 4) sorted by relevance
382 for (Waiter waiter : mTicketWaiters) { in abortWaitersOnCapacityDecrease()383 if (waiter.getRequestedTicketCount() > mCapacity) { in abortWaitersOnCapacityDecrease()384 toRemove.add(waiter); in abortWaitersOnCapacityDecrease()387 for (Waiter waiter : toRemove) { in abortWaitersOnCapacityDecrease()388 waiter.getDoneCondition().signal(); in abortWaitersOnCapacityDecrease()
195 for (Waiter waiter : mWaiters) { in close()196 waiter.getCondition().signal(); in close()
392 Runnable waiter = new Runnable() { in flushWorkerThread() local401 synchronized(waiter) { in flushWorkerThread()402 runOnWorkerThread(waiter); in flushWorkerThread()411 waiter.wait(); in flushWorkerThread()