当前位置:   article > 正文

使用 threading.Thread()多线程调用url接口服务,并通过封装 threading.Thread(),重写 run 方法获取调取后的结果_多线程访问url资源

多线程访问url资源
  1. import requests
  2. import threading
  3. # 测试案例json报文
  4. d_data = {
  5. }
  6. # 调用接口的url
  7. s_url = 'http://(ip或域名)/v1/rule_threshold'
  8. # 调用接口的函数
  9. def response_function(i, s_url, d_data):
  10. p_response = requests.post(s_url, json=d_data)
  11. # d_result = p_response.json()
  12. return p_response
  13. # 重构多线程
  14. class mythread(threading.Thread):
  15. def __init__(self, func, args=()):
  16. super(mythread, self).__init__()
  17. self.func = func
  18. self.args = args
  19. def run(self):
  20. self.result = self.func(*self.args)
  21. def get_result(self):
  22. try:
  23. return self.result
  24. except Exception:
  25. return None
  26. # 利用多线程方式调用接口
  27. # 创建线程列表
  28. threads = []
  29. # 创建并启动线程
  30. for i in range(20):
  31. thread = mythread(response_function, args=(i, s_url, d_data))
  32. thread.start()
  33. threads.append(thread)
  34. # 等待所有线程执行完毕,拿到执行结果
  35. for thread in threads:
  36. thread.join()
  37. print(thread.get_result().json())

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/小蓝xlanll/article/detail/172601
推荐阅读
相关标签
  

闽ICP备14008679号