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"表示所有任务都已经执行完成。
需要注意的是,在多线程任务调度中可能会存在线程安全的问题,需要使用锁等机制来保证数据的一致性和避免竞争条件。