Python如何获取多线程返回结果

目录 Python获取多线程返回结果 Python多线程实现

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')#等待线程全部执行完毕，才会执行该行代码

以上为个人经验，希望能给大家一个参考，也希望大家多多支持。

查看更多关于Python如何获取多线程返回结果的详细内容...