class MyThread(threading.Thread):
? ? def __init__(self, func, args = ()):
? ? ? ? super(MyThread, self).__init__()
? ? ? ? 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

然后我們就可以通過調(diào)用這個(gè)類里的函數(shù)，get_result() 來獲取每個(gè)線程中返回的結(jié)果了，以下是一個(gè)測試的實(shí)例，多線程調(diào)用一個(gè)相加的函數(shù)，經(jīng)過實(shí)驗(yàn)，是能夠獲取到所有線程返回的結(jié)果的。

import threading
class MyThread(threading.Thread):
? ? def __init__(self, func, args = ()):
? ? ? ? super(MyThread, self).__init__()
? ? ? ? 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
def add(num):
? ? result = num + 5
? ? return result
if __name__ == '__main__':
? ? data = []
? ? threads = []
? ? nums = [1, 2, 3]
? ? for num in nums:
? ? ? ? t = MyThread(add, args = (num, ))
? ? ? ? threads.append(t)
? ? ? ? t.start()
? ? for t in threads:
? ? ? ? t.join()
? ? ? ? data.append(t.get_result())
? ? print(data)

Python多線程實(shí)現(xiàn)

from threading import Thread
def func():
    for i in range(100):
        print('func',i)
if __name__ == '__main__':
    t=Thread(target=func)
    t.start()
    for i in range(100):
        print('main',i)

線程池：

一次性開辟一些線程，我們用戶直接給線程池子提交任務(wù)，線程任務(wù)的調(diào)度交給線程池。

from concurrent.futures import ThreadPoolExecutor
def func(name):
    for i in range(20):
        print(name,i)
if __name__ == '__main__':
    #創(chuàng)建線程池
    with ThreadPoolExecutor(10) as t:
        for i in range(10):
            t.submit(func,name=f'線程{i}')
    print('over')#等待線程全部執(zhí)行完畢，才會(huì)執(zhí)行該行代碼

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: