Python多線程是一種并發(fā)編程的方式，可以讓程序同時(shí)執(zhí)行多個(gè)任務(wù)苗膝。在Python中，多線程可以使用標(biāo)準(zhǔn)庫中的threading模塊來實(shí)現(xiàn)。本文將介紹如何使用threading模塊來創(chuàng)建和管理線程伶跷。
創(chuàng)建線程
在Python中，創(chuàng)建線程可以通過創(chuàng)建Thread對(duì)象來實(shí)現(xiàn)秘狞。Thread對(duì)象有一個(gè)target參數(shù)叭莫，指定線程要執(zhí)行的函數(shù)。例如：
import threading
def print_numbers():
for i in range(10):
print(i)
thread = threading.Thread(target=print_numbers)
thread.start()
在這個(gè)例子中烁试，我們創(chuàng)建了一個(gè)名為print_numbers的函數(shù)雇初，并將其作為Thread對(duì)象的target參數(shù)傳遞。然后我們調(diào)用start()方法來啟動(dòng)線程减响。當(dāng)線程啟動(dòng)后靖诗，它將調(diào)用print_numbers函數(shù)來執(zhí)行任務(wù)。
傳遞參數(shù)
有時(shí)候我們需要在線程中傳遞參數(shù)支示】伲可以通過在Thread對(duì)象的args參數(shù)中傳遞參數(shù)。例如：
import threading
def print_numbers(start, end):
for i in range(start, end):
print(i)
thread = threading.Thread(target=print_numbers, args=(1, 10))
thread.start()
在這個(gè)例子中颂鸿，我們傳遞了start和end兩個(gè)參數(shù)給print_numbers函數(shù)促绵。將這些參數(shù)作為元組傳遞給args參數(shù)，即args=(1, 10)。在print_numbers函數(shù)中绞愚，我們使用這些參數(shù)來打印數(shù)字叙甸。
線程同步
在多線程編程中，線程之間可能會(huì)訪問共享資源位衩。如果沒有適當(dāng)?shù)耐綑C(jī)制裆蒸，可能會(huì)導(dǎo)致競(jìng)態(tài)條件和死鎖等問題。Python提供了多種同步機(jī)制糖驴，例如鎖（Lock）僚祷、信號(hào)量（Semaphore）和條件變量（Condition）等。這里以鎖為例贮缕，介紹如何在Python中使用鎖來實(shí)現(xiàn)線程同步辙谜。
import threading
x = 0
lock = threading.Lock()
def increment():
global x
for i in range(100000):
lock.acquire()
x += 1
lock.release()
def decrement():
global x
for i in range(100000):
lock.acquire()
x -= 1
lock.release()
thread1 = threading.Thread(target=increment)
thread2 = threading.Thread(target=decrement)
thread1.start()
thread2.start()
thread1.join()
thread2.join()
print(x)
在這個(gè)例子中，我們定義了兩個(gè)函數(shù)increment和decrement感昼，分別對(duì)全局變量x進(jìn)行加一和減一操作装哆。為了避免競(jìng)態(tài)條件，我們使用Lock對(duì)象來控制對(duì)x的訪問定嗓。在increment和decrement函數(shù)中蜕琴，我們調(diào)用acquire()方法來獲取鎖，然后進(jìn)行相應(yīng)的操作宵溅，最后調(diào)用release()方法來釋放鎖凌简。這樣，每個(gè)線程在訪問x時(shí)都會(huì)先獲得鎖恃逻，從而避免了競(jìng)態(tài)條件雏搂。
在這個(gè)例子中，我們創(chuàng)建了兩個(gè)線程thread1和thread2寇损，分別執(zhí)行increment和decrement函數(shù)凸郑。我們通過調(diào)用start()方法來啟動(dòng)線程，然后通過調(diào)用join()方法來等待線程執(zhí)行完畢润绵。最后线椰，我們打印x的值，以檢查線程同步是否正確尘盼。
線程池
在Python中憨愉，可以使用ThreadPoolExecutor類來創(chuàng)建線程池，以便同時(shí)執(zhí)行多個(gè)任務(wù)卿捎。ThreadPoolExecutor可以自動(dòng)管理線程的數(shù)量和生命周期配紫，從而避免創(chuàng)建過多線程導(dǎo)致系統(tǒng)負(fù)載過高的問題。以下是一個(gè)簡(jiǎn)單的示例：
import concurrent.futures
def print_numbers(start, end):
for i in range(start, end):
print(i)
with concurrent.futures.ThreadPoolExecutor(max_workers=2) as executor:
executor.submit(print_numbers, 1, 5)
executor.submit(print_numbers, 6, 10)
在這個(gè)例子中午阵，我們使用ThreadPoolExecutor創(chuàng)建了一個(gè)最大工作線程數(shù)為2的線程池躺孝。然后我們通過調(diào)用submit()方法來提交兩個(gè)任務(wù)享扔，分別打印1到5和6到10之間的數(shù)字。submit()方法返回一個(gè)Future對(duì)象植袍，用于表示任務(wù)的執(zhí)行狀態(tài)和結(jié)果惧眠。在這個(gè)例子中，我們沒有使用Future對(duì)象來獲取任務(wù)的結(jié)果于个，而是直接打印數(shù)字氛魁。
Future對(duì)象的作用
Future對(duì)象是在Python標(biāo)準(zhǔn)庫中的concurrent.futures模塊中提供的一種異步編程工具，用于表示一個(gè)尚未完成的異步操作的狀態(tài)和結(jié)果厅篓。
當(dāng)一個(gè)任務(wù)被提交到線程池或者進(jìn)程池中時(shí)秀存，會(huì)立即返回一個(gè)Future對(duì)象。這個(gè)對(duì)象可以用于查詢?nèi)蝿?wù)的狀態(tài)和結(jié)果羽氮。Future對(duì)象有以下幾種狀態(tài)：
- PENDING：任務(wù)尚未開始執(zhí)行或链。
- RUNNING：任務(wù)正在執(zhí)行。
- CANCELLED：任務(wù)已被取消档押。
- FINISHED：任務(wù)已完成澳盐，可能成功也可能失敗。
當(dāng)任務(wù)完成后汇荐，F(xiàn)uture對(duì)象會(huì)保存任務(wù)的結(jié)果洞就，可以通過調(diào)用result()方法來獲取。如果任務(wù)尚未完成掀淘，調(diào)用result()方法會(huì)阻塞當(dāng)前線程，直到任務(wù)完成并返回結(jié)果或者拋出異常油昂。
除了result()方法之外革娄，F(xiàn)uture對(duì)象還提供了一些其他的方法，例如cancel()方法可以用于取消任務(wù)冕碟，done()方法用于檢查任務(wù)是否完成拦惋，add_done_callback()方法可以用于注冊(cè)回調(diào)函數(shù)，當(dāng)任務(wù)完成時(shí)自動(dòng)調(diào)用安寺。
綜合演示例子
面是一個(gè)綜合的例子厕妖，演示如何使用concurrent.futures模塊中的ThreadPoolExecutor和Future對(duì)象來實(shí)現(xiàn)并發(fā)下載圖片的功能。
import requests
import concurrent.futures
def download_image(url):
response = requests.get(url)
if response.status_code == 200:
filename = url.split("/")[-1]
with open(filename, "wb") as f:
f.write(response.content)
return filename
urls = [
"https://picsum.photos/200/300",
"https://picsum.photos/250/350",
"https://picsum.photos/300/400",
"https://picsum.photos/350/450",
"https://picsum.photos/400/500",
]
with concurrent.futures.ThreadPoolExecutor() as executor:
futures = [executor.submit(download_image, url) for url in urls]
for future in concurrent.futures.as_completed(futures):
filename = future.result()
if filename:
print(f"{filename} downloaded successfully!")
在這個(gè)例子中挑庶，我們定義了一個(gè)download_image()函數(shù)言秸，用于下載指定URL對(duì)應(yīng)的圖片，并將圖片保存到本地文件系統(tǒng)中迎捺。然后我們定義了一個(gè)URL列表urls举畸，包含了要下載的五張圖片的URL地址。
接下來凳枝，我們使用ThreadPoolExecutor創(chuàng)建一個(gè)線程池抄沮，并使用submit()方法提交五個(gè)下載任務(wù)。submit()方法返回一個(gè)Future對(duì)象，代表了提交的任務(wù)叛买。我們將所有的Future對(duì)象保存在一個(gè)列表中砂代。
然后，我們使用as_completed()函數(shù)遍歷所有的Future對(duì)象率挣，并在每個(gè)Future對(duì)象完成后調(diào)用result()方法獲取結(jié)果刻伊。如果下載成功，就打印出文件名难礼。
通過使用ThreadPoolExecutor和Future對(duì)象娃圆，我們可以同時(shí)下載多個(gè)圖片，從而提高下載速度蛾茉。同時(shí)讼呢，使用Future對(duì)象可以讓我們方便地處理每個(gè)任務(wù)的結(jié)果，從而實(shí)現(xiàn)更加靈活的異步編程谦炬。
總結(jié)
本文介紹了如何在Python中使用threading模塊來創(chuàng)建和管理線程悦屏，包括傳遞參數(shù)、線程同步和線程池等方面键思。同時(shí)础爬，我們也介紹了一些常見的多線程編程問題，例如競(jìng)態(tài)條件和死鎖等吼鳞，以及如何使用鎖來避免這些問題看蚜。在實(shí)際編程中，需要根據(jù)具體情況選擇適當(dāng)?shù)耐綑C(jī)制和線程池配置赔桌，以提高程序的性能和穩(wěn)定性供炎。
本文由mdnice多平臺(tái)發(fā)布
