Searched refs:threadPool (Results 1 – 3 of 3) sorted by relevance
118 ScheduledExecutorService threadPool = Executors.newScheduledThreadPool(11); in testConcurrent() local125 threadPool.submit(() -> { in testConcurrent()136 threadPool.submit(() -> { in testConcurrent()154 threadPool.schedule(() -> { in testConcurrent()160 threadPool.shutdownNow(); in testConcurrent()
252 ScheduledExecutorService threadPool = Executors.newScheduledThreadPool(11); in testConcurrent() local261 threadPool.submit(() -> { in testConcurrent()276 threadPool.submit(() -> { in testConcurrent()298 threadPool.schedule(() -> { in testConcurrent()310 threadPool.shutdownNow(); in testConcurrent()
488 final ExecutorService threadPool = in onUser() local526 threadPool.submit(getOnUserStartingRunnable(t, service, curUser)); in onUser()544 threadPool.submit(getOnUserCompletedEventRunnable( in onUser()561 threadPool.shutdown(); in onUser()563 terminated = threadPool.awaitTermination( in onUser()