Searched refs:pool (Results 1 – 3 of 3) sorted by relevance
106 with multiprocessing.Pool(processes=len(parsed_configs)) as pool:109 results.append(pool.apply_async(_run_test, args))110 pool.close()111 pool.join()
92 pool = common_operations.DevicePool(self.device_factory)93 pool.CreateDevices(5)95 self.assertEqual(len(pool.devices), 5)
109 WorkPool().use { pool -> in par_map() method116 pool.submit(Runnable { in par_map()