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 DThreadPoolImpl.java72 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 DThreadPoolExecutor.java433 * 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