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"表示所有任務都已經執行完成。
需要注意的是,在多線程任務調度中可能會存在線程安全的問題,需要使用鎖等機制來保證數據的一致性和避免競爭條件。