预先设定好线程池容量为 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
为什么要重复的启动线程呢
|