#thread-pool #rust

bin+lib hj_thread_pool

A simple thread pool implementation in Rust

1 unstable release

0.1.1 Aug 31, 2024
0.1.0 Aug 31, 2024

#1080 in Concurrency

Download history 230/week @ 2024-08-29 17/week @ 2024-09-05 6/week @ 2024-09-12

253 downloads per month

MIT/Apache

11KB
201 lines

HjThreadPool

HjThreadPool是一个简单的线程池实现,支持指定线程池中线程数量和日志级别。

Examples

use hj_thread_pool::{HjThreadPoolCfg, HjThreadPool, HjThreadPoolLogLevel};

fn main() {
    let pool = HjThreadPool::new(HjThreadPoolCfg {
        num_workers: 2,
        log_level: HjThreadPoolLogLevel::Debug,
    });
    pool.execute(|| {
        for i in 0..10 {
            println!("Task 1: {}", i);
            std::thread::sleep(std::time::Duration::from_secs(1));
        }
    });
}

create.io项目地址

https://crates.io/crates/hj_thread_pool


lib.rs:

HjThreadPool是一个简单的线程池实现,支持指定线程池中线程数量和日志级别。

Examples

use hj_thread_pool::{HjThreadPoolCfg, HjThreadPool, HjThreadPoolLogLevel};

fn main() {
    let pool = HjThreadPool::new(HjThreadPoolCfg {
        num_workers: 2,
        log_level: HjThreadPoolLogLevel::Debug,
    });
    pool.execute(|| {
        for i in 0..10 {
            println!("Task 1: {}", i);
            std::thread::sleep(std::time::Duration::from_secs(1));
        }
    });
}

Dependencies

~7–17MB
~196K SLoC