supervisor.py 文件源码

def __init__(
        self,
        worker_class,
        concurrent_workers,
    ):
        self.logger = logger.logger.Logger(
            logger_name='Supervisor',
        )

        self.worker_class = worker_class
        self.concurrent_workers = concurrent_workers

        self.task = self.worker_class()

        self.workers_processes = []

        self.should_work_event = threading.Event()
        self.should_work_event.set()

        multiprocessing.set_start_method(
            method='spawn',
            force=True,
        )