阅读量:0
在Python中,可以使用threading
模块来实现多线程任务分配。以下是一个简单的示例,展示了如何使用threading.Thread
类创建多个线程并分配任务:
- 首先,导入所需的模块:
import threading import time
- 定义一个函数,该函数将执行您要分配给多个线程的任务:
def worker(task_id): print(f"Task {task_id} started") time.sleep(2) # 模拟任务执行时间 print(f"Task {task_id} completed")
- 创建一个线程列表,用于存储要创建的线程对象:
threads = []
- 使用循环创建多个线程,并将它们添加到线程列表中。在这个例子中,我们将创建5个线程:
for i in range(5): thread = threading.Thread(target=worker, args=(i,)) threads.append(thread)
- 遍历线程列表,启动每个线程:
for thread in threads: thread.start()
- 等待所有线程完成:
for thread in threads: thread.join()
将上述代码放在一个Python文件中并运行,您将看到5个线程同时执行任务。您可以根据需要调整线程数量和任务函数。