Python多线程如何实现任务调度

Python中可以使用threading模块来实现多线程任务调度。以下是一个简单的示例代码:

import threading  def task1():     for i in range(5):         print("Task 1 - {}".format(i))  def task2():     for i in range(5):         print("Task 2 - {}".format(i))  # 创建线程 thread1 = threading.Thread(target=task1) thread2 = threading.Thread(target=task2)  # 启动线程 thread1.start() thread2.start()  # 等待线程结束 thread1.join() thread2.join()  print("All tasks are done") 

在上面的示例中，我们定义了两个任务task1和task2，然后创建了两个线程thread1和thread2来执行这两个任务。通过调用start()方法启动线程，然后使用join()方法等待线程执行完毕。最后输出"All tasks are done"表示所有任务都已经执行完成。

需要注意的是，在多线程任务调度中可能会存在线程安全的问题，需要使用锁等机制来保证数据的一致性和避免竞争条件。