Searched refs:threadPool (Results 1 – 4 of 4) 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()
154 threadPool *threadPool member386 f.threadPool = nil603 type threadPool struct { struct609 return &threadPool{921 threadPool.Run(948 threadPool.Wait()1000 f.threadPool.Wait()1038 f.threadPool.Wait()1256 f.threadPool.Run(1375 f.threadPool.Run([all …]
77 ScheduledExecutorService threadPool, in create() argument104 threadPool, afHoldSeconds, TimeUnit.SECONDS); in create()