Python获取多线程返回结果
在 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)
Python多线程实现
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')#等待线程全部执行完毕,才会执行该行代码
以上为个人经验,希望能给大家一个参考,也希望大家多多支持编程网。