判断是否被检测自动化增加文本条件, 登录, 获取账号信息, 修改账号信息, 检查账号cookies为无头模式运行. 获取任务更改为2个工作线程防止队列任务过多
This commit is contained in:
7
main.py
7
main.py
@@ -79,15 +79,15 @@ def main():
|
||||
# 存储正在运行的任务
|
||||
running_tasks = set()
|
||||
|
||||
# 创建线程池执行任务(3个工作线程)
|
||||
with ThreadPoolExecutor(max_workers=3) as executor:
|
||||
# 创建线程池执行任务(2个工作线程)
|
||||
with ThreadPoolExecutor(max_workers=2) as executor:
|
||||
while True:
|
||||
try:
|
||||
# 清理已完成的任务
|
||||
running_tasks = {task for task in running_tasks if not task.done()}
|
||||
|
||||
# 如果队列未满,尝试获取新任务
|
||||
if len(running_tasks) < 3:
|
||||
if len(running_tasks) < 2:
|
||||
task = get_task()
|
||||
if task:
|
||||
logger.info(f"收到任务: {task['id']} - {task['task_type']}")
|
||||
@@ -102,6 +102,7 @@ def main():
|
||||
time.sleep(10)
|
||||
else:
|
||||
# 达到最大并发数时等待
|
||||
logger.info("等待任务完成")
|
||||
time.sleep(1)
|
||||
|
||||
except Exception as e:
|
||||
|
||||
Reference in New Issue
Block a user