Searched refs:threadPool (Results 1 – 3 of 3) sorted by relevance
126 ScheduledExecutorService threadPool = Executors.newScheduledThreadPool(11); in testConcurrent() local133 threadPool.submit(() -> { in testConcurrent()144 threadPool.submit(() -> { in testConcurrent()162 threadPool.schedule(() -> { in testConcurrent()168 threadPool.shutdownNow(); in testConcurrent()
259 ScheduledExecutorService threadPool = Executors.newScheduledThreadPool(11); in testConcurrent() local268 threadPool.submit(() -> { in testConcurrent()283 threadPool.submit(() -> { in testConcurrent()305 threadPool.schedule(() -> { in testConcurrent()317 threadPool.shutdownNow(); in testConcurrent()
525 final ExecutorService threadPool = in onUser() local563 threadPool.submit(getOnUserStartingRunnable(t, service, curUser)); in onUser()581 threadPool.submit(getOnUserCompletedEventRunnable( in onUser()598 threadPool.shutdown(); in onUser()600 terminated = threadPool.awaitTermination( in onUser()