rustigo 1.1.4

A Rust webserver inspired by the Go standard library's HTTPServer
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

use crate::threadpool::pool::Job;
use std::sync::{mpsc, Arc, Mutex};
use std::thread;

/// A worker is a thread that listens for jobs on a receiver as part of a thread pool.
pub struct Worker {
    pub(super) id: usize,
    pub(super) thread: Option<thread::JoinHandle<()>>,
}

impl Worker {
    /// Create a new worker. The worker will listen for jobs on the receiver.
    pub fn new(id: usize, receiver: Arc<Mutex<mpsc::Receiver<Job>>>) -> Worker {
        let thread = thread::spawn(move || loop {
            // TODO: Remove unwraps
            let message = receiver.lock().unwrap().recv();

            match message {
                Ok(job) => job(),
                Err(e) => {
                    error!("Worker message not a job: {e}");
                    break;
                }
            }
        });

        let thread = Some(thread);

        Worker { id, thread }
    }
}