Python中可以使用threading
模塊來實現(xiàn)多線程任務(wù)調(diào)度。以下是一個簡單的示例代碼:
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))
# 創(chuàng)建線程
thread1 = threading.Thread(target=task1)
thread2 = threading.Thread(target=task2)
# 啟動線程
thread1.start()
thread2.start()
# 等待線程結(jié)束
thread1.join()
thread2.join()
print("All tasks are done")
在上面的示例中,我們定義了兩個任務(wù)task1
和task2
,然后創(chuàng)建了兩個線程thread1
和thread2
來執(zhí)行這兩個任務(wù)。通過調(diào)用start()
方法啟動線程,然后使用join()
方法等待線程執(zhí)行完畢。最后輸出"All tasks are done"表示所有任務(wù)都已經(jīng)執(zhí)行完成。
需要注意的是,在多線程任務(wù)調(diào)度中可能會存在線程安全的問題,需要使用鎖等機制來保證數(shù)據(jù)的一致性和避免競爭條件。