Initialize the worker boot sequence and start up all the worker threads.
(self)
| 103 | self.worker_threads = worker_threads |
| 104 | |
| 105 | def start(self) -> None: |
| 106 | """Initialize the worker boot sequence and start up all the |
| 107 | worker threads. |
| 108 | """ |
| 109 | self.broker.emit_before("worker_boot", self) |
| 110 | |
| 111 | worker_middleware = _WorkerMiddleware(self) |
| 112 | self.broker.add_middleware(worker_middleware) |
| 113 | for _ in range(self.worker_threads): |
| 114 | self._add_worker() |
| 115 | |
| 116 | self.broker.emit_after("worker_boot", self) |
| 117 | |
| 118 | def pause(self) -> None: |
| 119 | """Pauses all the worker threads.""" |