Function http_worker

perro_source/api_modules/perro_networking/src/http.rs:425–433

(config: HttpConfig, work_rx: Receiver<HttpWork>, event_tx: Sender<HttpEvent>)

        let (work_tx, work_rx) = mpsc::sync_channel::<HttpWork>(queue_config.request_capacity);
        let (event_tx, event_rx) = mpsc::sync_channel::<HttpEvent>(queue_config.event_capacity);
        let work_rx = Arc::new(Mutex::new(work_rx));
        let shared_agent = build_agent(&config).ok();
        for worker_index in 0..queue_config.worker_count {
            let worker_config = config.clone();
            let worker_rx = Arc::clone(&work_rx);
            let worker_event_tx = event_tx.clone();
            let worker_agent = shared_agent.clone();
            thread::Builder::new()
                .name(format!("perro-http-{worker_index}"))
                .spawn(move || http_worker(worker_config, worker_rx, worker_event_tx, worker_agent))
                .expect("failed to spawn HTTP worker");
        }