在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 = []
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个线程同时执行任务。您可以根据需要调整线程数量和任务函数。