Searched refs:workQueue (Results 1 – 1 of 1) sorted by relevance
406 private final BlockingQueue<Runnable> workQueue; field in ThreadPoolExecutor636 (runStateOf(c) == SHUTDOWN && ! workQueue.isEmpty())) in tryTerminate()811 BlockingQueue<Runnable> q = workQueue; in drainQueue()862 ! workQueue.isEmpty())) in addWorker()953 if (min == 0 && ! workQueue.isEmpty()) in processWorkerExit()987 if (rs >= SHUTDOWN && (rs >= STOP || workQueue.isEmpty())) { in getTask()1010 workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS) : in getTask()1011 workQueue.take(); in getTask()1128 BlockingQueue<Runnable> workQueue) { in ThreadPoolExecutor() argument1129 this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, in ThreadPoolExecutor()[all …]