std-threadpool 0.1.0

Threadpool implementation
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use std::io::Write;
use std::net::{TcpListener, TcpStream};
use std_threadpool::ThreadPool;

fn handle_client(mut stream: TcpStream) {
    stream.write_all(b"Hello world").unwrap();
}

fn main() {
    let listener = TcpListener::bind("127.0.0.1:1989").unwrap();
    let workers = ThreadPool::new(4);

    println!("Listening on 127.0.0.1:1989");

    for stream in listener.incoming() {
        workers
            .execute(|| {
                handle_client(stream.unwrap());
            })
            .unwrap();
    }
}