Python多线程:加速字典列表处理
在Python编程中,处理大量数据时,多线程能显著提升效率。本文将演示如何使用多线程并发处理包含多个字典的列表,并自定义线程数量。
假设我们有一个字典列表my_list,每个字典包含ip、password和user_name三个键值对,以及一个处理这些参数的函数dosome。我们需要将my_list中的每个字典传递给dosome函数执行,并通过控制线程数优化效率。
我们可以利用concurrent.futures模块中的ThreadPoolExecutor类创建线程池,高效管理多个线程。以下代码展示了如何使用ThreadPoolExecutor实现自定义线程数的多线程并发执行:
立即学习“Python免费学习笔记(深入)”;
# -*- coding: UTF-8 -*-import timefrom concurrent.futures import ThreadPoolExecutorimport threadingmy_list = [ {'ip': '192.168.1.2', 'password': '123456', 'user_name': '654321'}, {'ip': '192.168.1.3', 'password': '123456', 'user_name': '654321'}, {'ip': '192.168.1.4', 'password': '123456', 'user_name': '654321'}, {'ip': '192.168.1.5', 'password': '123456', 'user_name': '654321'}, {'ip': '192.168.1.6', 'password': '123456', 'user_name': '654321'}]def dosome(ip, password, user_name): thread_name = threading.current_thread().getName() time.sleep(1) # 模拟耗时操作 print(f'{thread_name}: Processing {ip}')with ThreadPoolExecutor(max_workers=3) as executor: # 创建线程池,最大线程数为3 for item in my_list: executor.submit(dosome, **item) # 使用**item解包字典作为参数
登录后复制
本文来自互联网或AI生成,不代表软件指南立场。本站不负任何法律责任。