# 项目名称 - **java-threadpool**: 这是一个跟java ThreadPoolExecutor线程池 使用方式基本相同的线程池 ## 快速开始 使用 java-threadpool的示例: // 创建线程池 let mut thre = ThreadPool::new(2, 5, 20); let mut vc = Vec::::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 方法处阻塞,等待队列内空出新的位置。