Lines Matching defs:threadPool
55 private ExecutorService threadPool;
59 threadPool = Executors.newCachedThreadPool();
66 threadPool.shutdown();
68 threadPool.awaitTermination(1, TimeUnit.SECONDS));
87 threadPool.submit(new Producer(q, 20));
88 threadPool.submit(new Producer(q, 20));
89 threadPool.submit(new Producer(q, 20));
90 threadPool.submit(new Producer(q, 20));
91 threadPool.submit(new Producer(q, 20));
112 Future<?> submitter = threadPool.submit(new Producer(q, 1));
160 threadPool.submit(new Producer(q, 1));
168 // when we shutdown the threadpool.
179 threadPool.submit(new Interrupter(Thread.currentThread()));
195 threadPool.submit(new Runnable() {
240 threadPool.submit(new Interrupter(Thread.currentThread()));
256 threadPool.submit(new Interrupter(Thread.currentThread()));
