消息队列在python中的使用queue

时间:2022-11-17 17:37:25

本文主要介绍python中用来实现线程间通信的消息队列模块Queue,主要包括:

  • 模块介绍
  • API介绍

一、模块介绍

Queue模块用来实现消息队列功能,可以实现线程间安全的消息交换。各个线程可以通过调用消息队列实例对消息队列进行操纵。


二、API介绍

该模块包含以下函数:

1.Queue.qsize()

该函数返回消息队列的当前空间。

2.Queue.empty()

该函数判断消息队列是否为空,返回True或False。

3.Queue.full()

该函数判断消息队列是否满,返回True或False。

4.Queue.put(item, block=True, timeout=None)

该函数用来消息队列中存放消息。block参数可以控制是否阻塞,timeout指定阻塞的等待时间。如果不阻塞或者超时,会引起一个full exception。

5.Queue.put_nowait(item)

该函数相当于put(item, False)。

6.Queue.get(block=True, timeout=None)

该函数用于获取消息,其他同put相同。

7.Queue.task_done()

该函数接受消息的线程通过调用这个函数来说明消息对应的任务已完成。

8.Queue.join()

该函数调用线程阻塞直到所有消息对应的任务已经完成。