下载安卓APP箭头
箭头给我发消息

客服QQ:3315713922

python应用:Python3标准库,queue线程安全的FIFO实现

作者:@小灰灰     来源: https://www.cnblogs.com/liuhui0308/p/12343274.html点击数:813发布时间: 2020-02-24 13:19:35

标签: python编程语言Python语言

大神带你学编程,欢迎选课

1. queue线程安全的FIFO实现

  Python是一种解释型脚本语言,可以应用于以下领域:

  web和Internet开发

  科学计算和统计

  人工智能

  教育

  桌面界面开发

  软件开发

  后端开发

  网络爬虫

queue模块提供了一个适用于多线程编程的先进先出(FIFO,first-in,first-out)数据结构,可以用来在生产者和消费者线程之间安全地传递消息或其他数据。它会为调用者处理锁定,使多个线程可以安全而容易地处理同一个Queue实例。Queue的大小(其中包含的元素个数)可能受限,以限制内存使用或处理。

 1.1 基本FIFO队列

Queue类实现了一个基本的先进先出容器。使用put()将元素增加到这个序列的一端,使用get()从另一端删除。

  1. import queue
  2. q = queue.Queue()
  3. for i in range(5):
  4. q.put(i)
  5. whilenot q.empty():
  6. print(q.get(),end='')
  7. print()

这个例子使用了一个线程来展示按插入元素的相同顺序从队列删除元素。

 1.2 LIFO队列

与Queue的标准FIFO实现相反,LifoQueue使用了(通常与栈数据结构关联的)后进后出(LIFO,last-in,first-out)顺序。

  1. import queue
  2. q = queue.LifoQueue()
  3. for i in range(5):
  4. q.put(i)
  5. whilenot q.empty():
  6. print(q.get(),end='')
  7. print()

get将删除最近使用put插入到队列的元素。

 1.3 优先队列

有些情况下,需要根据队列中元素的特性来决定这些元素的处理顺序,而不是简单地采用在队列中创建或插入元素的顺序。例如,工资部门的打印作业可能就优先于某个开发人员想要打印的代码清单。PriorityQueue使用队列内容的有序顺序来决定获取哪一个元素。

  1. import functools
  2. import queue
  3. import threading
  4. @functools.total_ordering
  5. classJob:
  6. def__init__(self, priority, description):
  7. self.priority = priority
  8. self.description = description
  9. print('New job:', description)
  10. return
  11.  
  12. def__eq__(self, other):
  13. try:
  14. returnself.priority == other.priority
  15. exceptAttributeError:
  16. returnNotImplemented
  17. def__lt__(self, other):
  18. try:
  19. returnself.priority < other.priority
  20. exceptAttributeError:
  21. returnNotImplemented
  22. q = queue.PriorityQueue()
  23. q.put(Job(3,'Mid-level job'))
  24. q.put(Job(10,'Low-level job'))
  25. q.put(Job(1,'Important job'))
  26. def process_job(q):
  27. whileTrue:
  28. next_job = q.get()
  29. print('Processing job:', next_job.description)
  30. q.task_done()
  31. workers =[
  32. threading.Thread(target=process_job, args=(q,)),
  33. threading.Thread(target=process_job, args=(q,)),
  34. ]
  35. for w in workers:
  36. w.setDaemon(True)
  37. w.start()
  38. q.join()

这个例子有多个线程在处理作业,要根据调用get()时队列中元素的优先级来处理。运行消费者线程时,增加到队列的元素的处理顺序取决于线程上下文切换。

python应用:Python3标准库,queue线程安全的FIFO实现_python_编程语言_Python语言_课课家Python是一种跨平台的计算机程序设计语言。是一种面向对象的动态类型语言,最初被设计用于编写自动化脚本(shell),随着版本的不断更新和语言新功能的添加,越多被用于独立的、大型项目的开发。

赞(8)
踩(0)
分享到:
华为认证网络工程师 HCIE直播课视频教程