Lines Matching defs:tpe
143 static void checkTerminated(ThreadPoolExecutor tpe) {
145 check(tpe.getQueue().isEmpty());
146 check(tpe.isShutdown());
147 check(tpe.isTerminated());
148 check(! tpe.isTerminating());
149 equal(tpe.getActiveCount(), 0);
150 equal(tpe.getPoolSize(), 0);
151 equal(tpe.getTaskCount(), tpe.getCompletedTaskCount());
152 check(tpe.awaitTermination(0, TimeUnit.SECONDS));
199 CheckingExecutor tpe = new CheckingExecutor();
202 tpe.execute(task);
206 equal(tpe.getTaskCount(),
208 equal(tpe.getCompletedTaskCount(),
209 (long) flakes.size() - tpe.getCorePoolSize());
216 while (tg.activeCount() != tpe.getCorePoolSize() ||
217 tg.activeCount() != tpe.getCorePoolSize())
219 equal(tg.activeCount(), tpe.getCorePoolSize());
221 tpe.shutdown();
223 check(tpe.awaitTermination(10L, TimeUnit.MINUTES));
224 checkTerminated(tpe);
243 equal(tpe.getCompletedTaskCount(), (long) flakes.size());
247 tpe.shutdown();
248 tpe.shutdownNow();
249 check(tpe.awaitTermination(10L, TimeUnit.MINUTES));
250 checkTerminated(tpe);