Searched defs:workQueue (Results 1 - 2 of 2) sorted by relevance
/openjdk7/corba/src/share/classes/com/sun/corba/se/impl/orbutil/threadpool/ |
H A D | ThreadPoolImpl.java | 72 private WorkQueue workQueue; field in class:ThreadPoolImpl 119 workQueue = new WorkQueueImpl(this); 143 workQueue = new WorkQueueImpl(this); 243 ((WorkQueueImpl)workQueue).getMonitoredObject()); 254 return workQueue; 262 return workQueue; 267 * workQueue. This method would create new threads if required 344 synchronized (workQueue) { 382 synchronized (workQueue) { 388 synchronized (workQueue) { [all...] |
/openjdk7/jdk/src/share/classes/java/util/concurrent/ |
H A D | ThreadPoolExecutor.java | 433 * threads. We do not require that workQueue.poll() returning 434 * null necessarily means that workQueue.isEmpty(), so rely 442 private final BlockingQueue<Runnable> workQueue; field in class:ThreadPoolExecutor 692 (runStateOf(c) == SHUTDOWN && ! workQueue.isEmpty())) 850 BlockingQueue<Runnable> q = workQueue; 902 ! workQueue.isEmpty())) 1012 if (min == 0 && ! workQueue.isEmpty()) 1046 if (rs >= SHUTDOWN && (rs >= STOP || workQueue.isEmpty())) { 1069 workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS) : 1070 workQueue 1193 ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) argument 1227 ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory) argument 1262 ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler) argument 1299 ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler) argument [all...] |
Completed in 29 milliseconds