在 Python 的多线程中,有时候我们会需要每一个线程中返回的结果。
然而,在经过我的多番尝试、以及网上各种博客显示,在 Python3 中是无法获得单个线程中返回的结果的,因此我们需要定义一个类来实现这个过程
这个类的定义如下:
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
然后我们就可以通过调用这个类里的函数,get_result() 来获取每个线程中返回的结果了,以下是一个测试的实例,多线程调用一个相加的函数,经过实验,是能够获取到所有线程返回的结果的。
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)
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)
线程池:
from concurrent.futures import ThreadPoolExecutor def func(name): for i in range(20): print(name,i) if __name__ == '__main__': #创建线程池 with ThreadPoolExecutor(10) as t: for i in range(10): t.submit(func,name=f'线程{i}') print('over')#等待线程全部执行完毕,才会执行该行代码
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:mmqy2019@163.com进行举报,并提供相关证据,查实之后,将立刻删除涉嫌侵权内容。
长按识别二维码并关注微信
更方便到期提醒、手机管理