线程通信-通过queque的方式进行线程通信

左手的ㄟ右手 2023-07-17 14:19 90阅读 0赞 
  1. from queue import Queue
  3. import time
  4. import threading
  6. def get_detail_html(queue):
  7.     while True:
  8.         url =queue.get()
  9.     print(" get detail html started")
  10.     time.sleep(2)
  11.     print("get detail html end")
  15. def get_detail_url(queue):
  16.     while True:
  17.         print(" get detail url started")
  18.         time.sleep(2)
  19.         for i in range(20):
  20.             queue.put("https://123.com")
  21.         print("get detail url end")
  25. if __name__ == '__main__':
  26.     detail_queue = Queue(maxsize=1000) # 创建一个消息队列
  27.     # 创建一个线程给队列中添加数据
  28.     thread_detail_url = threading.Thread(target=get_detail_url,args=(detail_queue,))
  29.     # 开启10个线程并
  30.     for i in range(10):
  31.         html_thread = threading.Thread(target=get_detail_html,args=(detail_queue,))
  32.         html_thread.start()
  33.     # 队列阻塞直到执行完
  34.     detail_queue.join()
  35.     # detail_queue.task_done()# 退出

发表评论

表情：
评论列表 （有 0 条评论，90人围观）

还没有评论，来说两句吧...

相关阅读