多线程如何获取结果?
更多精彩文章请关注公众号『大海的BLOG』
1.场景
大家一般都会开启多线程去处理任务,如果需要获取线程处理结果怎么办?
有人会说『全局变量』,但是又会引出共享全局变量后资源竞争导致数据错误的问题。只能通过添加互斥锁进行解决,互斥锁又不能发挥多线程的优势,很是头大。
那么该如何解决呢?
2.解决办法
可以自定义一个类解决:
import threading
class MyThread(threading.Thread):
def __init__(self, func, args):
super(MyThread, self).__init__()
self.func = func
self.args = args
self.result = self.func(*self.args)
def get_result(self):
threading.Thread.join(self)
try:
return self.result
except:
return None
使用方式:直接创建一个对象 thread
,在使用方法 thread.start()
后,再调用 get_result()
方法即可获取。
更多精彩文章请关注公众号『大海的BLOG』