# 项目名称
- **java-threadpool**: 这是一个跟java ThreadPoolExecutor线程池 使用方式基本相同的线程池
## 快速开始
使用 java-threadpool的示例:
// 创建线程池
let mut thre = ThreadPool::new(2, 5, 20);
let mut vc = Vec::<Future>::new();
for i in 0..10 {
// 向线程池内提交闭包(执行的逻辑)
let future = thre.executor(|| {
thread::sleep(Duration::from_secs(5));
println!("HELLO WORLD");
});
// 将返回的 Future 对象存储在vec内
vc.push(future);
}
for v in vc{
// 阻塞线程,等待提交的闭包执行完成
v.get();
}
// 关闭线程池
thre.shutdown();
## ThreadPool::new() 参数的含义是:
- **core_pool_size**: 核心线程数,就是常驻线程数。
- **maximum_pool_size**: 最大线程数,这个参数必须比核心线程数大。
- **maximum_queue**: 等待执行线程的队列长度。最大有多少个任务等待,
如果线程提交数量超过 core_pool_size + maximum_pool_size +maximum_queue
那么线程会在 thre.executor 方法处阻塞,等待队列内空出新的位置。