Commit 186a8051 by baiquan

refactor(shop): 调整线程池参数设置

- 将外层线程池大小和内层线程池大小的配置移至主程序入口
- 优化代码结构,提高可读性和可维护性
-确保线程池参数在程序开始时正确设置
parent e00f6687
...@@ -227,6 +227,10 @@ async def run(task_type): ...@@ -227,6 +227,10 @@ async def run(task_type):
if __name__ == '__main__': if __name__ == '__main__':
# 外层线程池大小
OUTER_MAX_WORKERS = 5
# 内层线程池大小(每个任务)
INNER_MAX_WORKERS = 3
argv = sys.argv argv = sys.argv
try: try:
if len(argv) != 2: if len(argv) != 2:
...@@ -246,10 +250,6 @@ if __name__ == '__main__': ...@@ -246,10 +250,6 @@ if __name__ == '__main__':
INNER_MAX_WORKERS = 1 INNER_MAX_WORKERS = 1
time.sleep(10) time.sleep(10)
elif task_type == TaskType.DOUDIAN_UPLOAD_IMAGE_AND_VIDEO: elif task_type == TaskType.DOUDIAN_UPLOAD_IMAGE_AND_VIDEO:
# 外层线程池大小
OUTER_MAX_WORKERS = 5
# 内层线程池大小(每个任务)
INNER_MAX_WORKERS = 3
time.sleep(1) time.sleep(1)
else: else:
time.sleep(5) time.sleep(5)
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment