如何实现分批执行线程

[Arabot9]

预先设定好线程池容量为 50，

1、如何实现 10 个线程为一组执行，执行完这一组继续执行下一组十个线程？

2、如何实现设定最大同时任务数为 10 个线程，当中有线程结束后，剩下未执行的线程替补进来？

感谢解答！

[Juszoe]

1. 每次启动十个线程，用 join 等待线程全部完成，再创建十个
2. 这不就是线程池为 10 的意思吗
可能我没理解你的意思，“预先设定好线程池容量为 50”是要做什么？

[ClericPy]

https://docs.python.org/zh-cn/3/library/concurrent.futures.html#concurrent.futures.ThreadPoolExecutor

看看 Future 是个什么设计会帮助了解很多

当然老版本的 from multiprocessing.dummy import Pool 也依然可以用

[ClericPy]

如果非要自己实现, Semphore 的用途应该就是限定并发用的, 用法和别的锁差不多

[lithbitren]

搞一个定容的 queue 队列，get 拿任务推到工厂也可以。

[524758861]

1.Executors.newFixedThreadPool(10)建立线程池，然后把任务 submit 进去 Callable，然后等待 10 个都执行完，需要 Future 的 get 去阻塞到全部执行完毕
2.Executors.newFixedThreadPool(10)建立线程池，把任务全部 submit 进去 Runable，会自动替补的

[mlyy]

https://joblib.readthedocs.io/en/latest/

[lqw3030]

为什么要重复的启动线程呢