Python3标准库：queue线程安全的FIFO实现

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Python3标准库：queue线程安全的FIFO实现，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2044字，纯文字阅读大概需要3分钟。

内容图文

1. queue线程安全的FIFO实现

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

1.1 基本FIFO队列

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

import queue

q = queue.Queue()

for i in range(5):
    q.put(i)

while not q.empty():
    print(q.get(), end=' ')
print()

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

1.2 LIFO队列

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

import queue

q = queue.LifoQueue()

for i in range(5):
    q.put(i)

while not q.empty():
    print(q.get(), end=' ')
print()

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

1.3 优先队列

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

import functools
import queue
import threading

@functools.total_ordering
class Job:

    def __init__(self, priority, description):
        self.priority = priority
        self.description = description
        print('New job:', description)
        return

    def __eq__(self, other):
        try:
            return self.priority == other.priority
        except AttributeError:
            return NotImplemented

    def __lt__(self, other):
        try:
            return self.priority < other.priority
        except AttributeError:
            return NotImplemented

q = queue.PriorityQueue()

q.put(Job(3, 'Mid-level job'))
q.put(Job(10, 'Low-level job'))
q.put(Job(1, 'Important job'))

def process_job(q):
    while True:
        next_job = q.get()
        print('Processing job:', next_job.description)
        q.task_done()

workers = [
    threading.Thread(target=process_job, args=(q,)),
    threading.Thread(target=process_job, args=(q,)),
]
for w in workers:
    w.setDaemon(True)
    w.start()

q.join()

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

内容总结

以上是互联网集市为您收集整理的Python3标准库：queue线程安全的FIFO实现全部内容，希望文章能够帮你解决Python3标准库：queue线程安全的FIFO实现所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端