预先设定好线程池容量为 50，
1、如何实现 10 个线程为一组执行，执行完这一组继续执行下一组十个线程？
2、如何实现设定最大同时任务数为 10 个线程，当中有线程结束后，剩下未执行的线程替补进来？
感谢解答！
 |
1
Juszoe 2020-03-20 23:04:54 +08:00
1. 每次启动十个线程，用 join 等待线程全部完成，再创建十个
2. 这不就是线程池为 10 的意思吗 可能我没理解你的意思，“预先设定好线程池容量为 50”是要做什么？ |
 |
2
ClericPy 2020-03-20 23:10:16 +08:00  1
https://docs.python.org/zh-cn/3/library/concurrent.futures.html#concurrent.futures.ThreadPoolExecutor
看看 Future 是个什么设计会帮助了解很多 当然老版本的 from multiprocessing.dummy import Pool 也依然可以用 |
|
3
ClericPy 2020-03-20 23:11:08 +08:00
如果非要自己实现, Semphore 的用途应该就是限定并发用的, 用法和别的锁差不多
|
 |
4
lithbitren 2020-03-21 00:19:10 +08:00
搞一个定容的 queue 队列，get 拿任务推到工厂也可以。
|
 |
5
524758861 2020-03-21 03:22:35 +08:00
1.Executors.newFixedThreadPool(10)建立线程池，然后把任务 submit 进去 Callable，然后等待 10 个都执行完，需要 Future 的 get 去阻塞到全部执行完毕
2.Executors.newFixedThreadPool(10)建立线程池，把任务全部 submit 进去 Runable，会自动替补的 |
 |
6
mlyy 2020-03-21 06:42:27 +08:00 via iPhone
|
 |
7
lqw3030 2020-03-21 10:13:00 +08:00
为什么要重复的启动线程呢
|
Select Language