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

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

2023-02-06 11:19vv安的浅唱 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')#等待线程全部执行完毕，才会执行该行代码