Searched refs:executor (Results 1 – 3 of 3) sorted by relevance
68 final ExecutorService executor = Executors.newSingleThreadExecutor(); field in CrashTestService103 executor.submit(() -> { in onBind()138 executor.shutdown(); in onUnbind()
308 with concurrent.futures.ThreadPoolExecutor(max_workers=30) as executor:310 future_to_params = {executor.submit(func, *p): p for p in param_list}
359 with futures.ThreadPoolExecutor(max_workers=n_workers) as executor:361 executor.submit(self.RunLtpWorker, q, args, name_func, i)