Searched refs:workerPool (Results 1 – 1 of 1) sorted by relevance
100 val workerPool: ExecutorService = Executors.newFixedThreadPool(4) in insertRecordsForPerformanceTestingInParallel() constant103 workerPool.execute { in insertRecordsForPerformanceTestingInParallel()115 workerPool.shutdown() in insertRecordsForPerformanceTestingInParallel()116 workerPool.awaitTermination(2, TimeUnit.MINUTES) in insertRecordsForPerformanceTestingInParallel()