Searched refs:executor (Results 1 – 6 of 6) sorted by relevance
61 self.executor = concurrent.futures.ThreadPoolExecutor(max_workers=1)62 self.future = self.executor.submit(self.__logging_loop)74 self.executor.shutdown(wait=False)
79 self.executor = ThreadPoolExecutor()80 self.future = self.executor.submit(EventStream.__event_loop, self)106 self.executor.shutdown(wait=False)
12 use futures::executor::block_on;
9 use futures::executor::block_on;
417 auto executor = executors.find(command.workload); in main() local418 if (executor == executors.end()) continue; in main()419 executor->second(&collector, command); in main()
789 executor = ThreadPoolExecutor(jobs)809 executor.submit(task, function, dso_info)810 executor.shutdown(wait=True)