INNER CODE UNIT · Python

_start_yolo_worker

yihong1120/Construction-Hazard-Detection · main.py:619

    def _start_yolo_worker(
        self,
        worker_index: int,
        request_queue: Any,
        device: str,
    ) -> Process:
        """Start one worker against fixed native request/result queues."""
        result_queues = {
            camera_id: result_queue
            for camera_id, result_queue in self.yolo_result_queues.items()
            if self.yolo_worker_camera_slots.get(camera_id) == worker_index
        }
        worker = YoloWorker(
            request_queue,
            device,
            result_queues=result_queues,
            startup_lock=self.yolo_worker_startup_lock,
        )

View source record →