python使用ThreadPoolExecutor每秒并发5个
2023-09-14 09:06:35 时间
import time
from concurrent.futures import ThreadPoolExecutor
from functools import partial
from loguru import logger
max_items = 2
def gen():
for i in range(30):
yield i
def all_review_demo(url,m="Data"):
logger.info("in all_review_demo")
print(m,url)
PREFIX = "demo"
geno_bj = gen()
m=2
while True:
try:
l = [next(geno_bj) for i in range(5)]
start = time.time()
with ThreadPoolExecutor(max_workers=5) as pool:
try:
pool.map(partial(all_review_demo,m=m), l)
except Exception as e:
logger.info(f"{PREFIX}--出现错误,错误原因:{e.args}")
end = time.time() - start
if end < 1:
wait =1-end
logger.info("等待",wait)
time.sleep(1 - end)
except StopIteration as e:
break
相关文章
- pycharm连接不上mysql中的数据库时_python Mysql时间带t
- python详细安装教程环境配置_Python配置环境
- Python里divmod_python yield函数
- python chr()和ord()_Python函数ord
- pycharm怎么更新包_python 开发web项目
- 如何用 Python 发送通知到微信?
- python调用通达信公式_通达信公式-主力雷达Python化[通俗易懂]
- python中的math模块的简单使用
- python设置时间过期改变状态_Python Redis设置过期时间「建议收藏」
- python deepcopy函数_Python deepcopy
- 正则表达式Python_python正则表达式匹配字符串
- python分段线性插值_Python实现分段线性插值
- python type error是什么意思_Python 报错 TypeError:’DoesNotExist’对象不可调用
- 使用Python对Excel数据进行排序,更高效!
- Python学习-Chapter6 字典
- App自动化测试|Appium+Python自动化测试环境搭建(Windows)
- 【2023新书】贝叶斯统计建模:使用Stan、R和Python
- python-Python与MongoDB数据库-使用Python执行MongoDB查询(三)
- Python学习:6.python内置函数详解编程语言
- 第一个python程序-判断登陆用户名和密码是否正确详解编程语言
- Linux中运行Python文件的步骤(linux运行python文件)
- python已知三点计算三角形面积详解编程语言
- 快速安装Python MySQL模块(python安装mysql模块)
- 掌握Linux环境下的Python编程(linux执行python)
- 使用Python连接SQL Server数据库(python连接sqlserver)
- 利用Neo4j和Python进行无缝图形数据库支持(neo4j python)
- Linux中如何离开Python环境(linux怎么退出python)
- python切片和range()用法说明
- Linux下Python获取IP地址的代码
- python正则表达式re模块详解