Python多线程获取返回值代码实例

重写threading类以支持获取返回值

Python标准库中的threading模块默认不提供直接获取线程返回值的功能。为了实现这一目标，我们可以继承threading.Thread类并重写其run方法。在run方法中，我们调用目标函数并将结果保存到实例变量中。同时，提供一个get_result()方法来获取该结果。

import threading
class MyThread(threading.Thread):
  """重写多线程，使其能够返回值"""
  def __init__(self, target=None, args=()):
    super(MyThread, self).__init__()
    self.func = target
    self.args = args

  def run(self):
    self.result = self.func(*self.args)

  def get_result(self):
    try:
      return self.result # 如果子线程不使用join方法，此处可能会报没有self.result的错误
    except Exception:
      return None

调用get_result()方法获取结果

在自定义的MyThread类中，我们重写了run方法，使其在执行目标函数后，将结果保存到self.result属性中。然后，通过get_result()方法，主线程可以安全地获取子线程的执行结果。

def parse_detail_page(self,items_list):
  retval, RetList, _Threads = [], [], []
  for url in items_list:
    t = MyThread(target=self.threadItem, args=(url,))
    t.start()
    _Threads.append(t)
  for t in _Threads:
    t.join()
    retval.append(t.get_result())
def threadItem(self,url):
  """多线程请求""" 
 response = requests.get(url)
  return response.text

最终列表retval是多线程返回值的集合

在parse_detail_page函数中，我们遍历items_list列表，为每个URL创建一个MyThread实例，并启动线程。然后，将所有线程对象添加到_Teards列表中。接着，我们遍历_Teards列表，对每个线程调用join()方法，确保子线程执行完毕后再获取其结果。最后，将每个线程的返回值添加到retval列表中。

以上就是Python多线程获取返回值代码实例的详细内容，更多关于Python多线程的资料请关注本站其它相关文章！