在Python中,可以使用threading
模塊來實現多線程并發代碼。下面是一個簡單的示例:
import threading
# 定義一個函數作為線程的執行體
def thread_task():
# 這里寫線程的具體邏輯
print("Thread is running")
# 創建線程對象
thread = threading.Thread(target=thread_task)
# 啟動線程
thread.start()
# 等待線程結束
thread.join()
print("Main thread is done")
在上面的示例中,首先定義了一個函數thread_task
作為線程的執行體,然后創建了一個線程對象thread
,并將thread_task
函數作為參數傳入target
參數中。然后通過start
方法啟動線程,線程開始執行。join
方法會阻塞主線程,直到線程執行結束。最后輸出"Main thread is done"表示主線程執行完畢。
這只是一個簡單的示例,實際應用中可能需要處理更復雜的并發邏輯,例如使用鎖、線程通信等。在處理多線程并發時,需要注意線程間的資源競爭問題,確保線程安全。