python多線(xiàn)程如何獲取有序結(jié)果

更新時(shí)間：2024年09月10日 08:34:36 作者：我是誰(shuí)，我在哪，我在干啥

在Python中,多線(xiàn)程編程是一個(gè)常見(jiàn)需求,尤其是在處理I/O密集型任務(wù)時(shí),然而,多線(xiàn)程環(huán)境下保持任務(wù)執(zhí)行結(jié)果的順序通常較為復(fù)雜,為了解決這一問(wèn)題,可以通過(guò)封裝一個(gè)功能來(lái)確保即使在多線(xiàn)程環(huán)境下,任務(wù)的執(zhí)行結(jié)果也能按照一定的順序進(jìn)行收集和處理

python多線(xiàn)程獲取有序結(jié)果

功能封裝

import threading

class MyThread(threading.Thread):
    def __init__(self, func, args, name=''):
        threading.Thread.__init__(self)
        self.name = name
        self.func = func
        self.args = args
        
    def run(self):
        self.result = self.func(*self.args)
        
    def get_result(self):
        try:
            return self.result
        except Exception:
            return None

執(zhí)行

def main():
    threads = []
    nloops = 函數(shù)列表
    for i in nloops:
        t = MyThread(函數(shù), (參數(shù),))
        threads.append(t)
    for i in threads :   # start threads 此處并不會(huì)執(zhí)行線(xiàn)程，而是將任務(wù)分發(fā)到每個(gè)線(xiàn)程，同步線(xiàn)程。等同步完成后再開(kāi)始執(zhí)行start方法
        i.start()
    results= []
    for i in threads:   # jion()方法等待線(xiàn)程完成
        i.join()
        results.append(i.get_result())  # 獲取所有結(jié)果列表
    print(threads[1].get_result())  # 獲取其中一個(gè)結(jié)果

python同步應(yīng)用：多個(gè)線(xiàn)程有序執(zhí)行

可以使用互斥鎖完成多個(gè)任務(wù)，有序的進(jìn)程工作，這就是線(xiàn)程的同步

from threading import Thread, Lock
import time
mutex1= Lock()  # 創(chuàng)建一個(gè)互斥鎖
mutex2= Lock()  # 創(chuàng)建一個(gè)互斥鎖
mutex3= Lock()  # 創(chuàng)建一個(gè)互斥鎖
 
 
def fun1():
    while 1:
        mutex1.acquire()  # 阻塞
        print("線(xiàn)程1 執(zhí)行")
        mutex2.release()   # 釋放鎖2，讓線(xiàn)程2繼續(xù)執(zhí)行
        time.sleep(0.1)
 
 
def fun2():
    while 1:
        mutex2.acquire()  # 阻塞
        print("線(xiàn)程2 執(zhí)行")
        mutex3.release()   # 釋放鎖3，讓線(xiàn)程3繼續(xù)執(zhí)行
        time.sleep(0.1)
 
 
def fun3():
    while 1:
        mutex3.acquire()  # 阻塞
        print("線(xiàn)程3 執(zhí)行")
        mutex1.release()   # 釋放鎖1，讓線(xiàn)程1繼續(xù)執(zhí)行
        time.sleep(0.1)
 
t1 =Thread(target=fun1)  # 創(chuàng)建一個(gè)線(xiàn)程對(duì)象
t2 =Thread(target=fun2)  # 創(chuàng)建一個(gè)線(xiàn)程對(duì)象
t3 =Thread(target=fun3)  # 創(chuàng)建一個(gè)線(xiàn)程對(duì)象
 
mutex2.acquire()  # 將鎖2設(shè)置為上鎖，線(xiàn)程2不能運(yùn)行
mutex3.acquire()  # 將鎖2設(shè)置為上鎖，線(xiàn)程2不能運(yùn)行
 
t1.start()  # 開(kāi)啟線(xiàn)程的執(zhí)行
t2.start()
t3.start()
 
t1.join()  # 回收線(xiàn)程資源
t2.join()
t3.join()