python 循环队列的实现

　　最近在作一个东西的时候发现须要用到循环队列，实现先进先出（FIFO），不断往里面添加数据，当达到某个限定值时，最早进去的出去，而后再添加。以后须要对队列里面的内容进行一个筛选，做其余处理。首先我想到了python的Queue模块，先简单的介绍一下，具体的能够参考Queue。

1、Queue模块

Python queue模块有三种队列及构造函数:
　　一、Python queue模块的FIFO队列先进先出。     class queue.queue(maxsize)
　　二、LIFO相似于堆栈，即先进后出。                         class queue.Lifoqueue(maxsize)
　　三、还有一种是优先级队列级别越低越先出来。    class queue.Priorityqueue(maxsize)

此包中的经常使用方法(q =queue.queue()):
　　q.qsize() 返回队列的大小

　　q.empty() 若是队列为空，返回True,反之False

　　q.full() 若是队列满了，返回True,反之False

　　q.get(block=True, timeout=None]) 从队列中返回并删除一个元素，timeout等待时间

　　q.get_nowait() 至关q.get(False)

　　q.put(item, block=True, timeout=None）非阻塞 q.put(item) 写入队列，timeout等待时间

　　q.put_nowait(item) 至关q.put(item, False)

　　q.task_done() 在完成一项工做以后，q.task_done() 函数向任务已经完成的队列发送一个信号

　　q.join() 实际上意味着等到队列为空，再执行别的操做

　　

　　这里引入Queue模块就能够实现FIFO了，当我要提取队列里面的数据的时候，我得利用get()方法先把数据提取出来，而后存入一个新的数组，因为我要隔一段时间对里面的数据进行提取，而get()方法提取的时候会删除对应的元素，这样有点儿不方便。所以我本身写了一个类（写的很差的地方，大神们能够告诉我，不喜勿喷hh）

 

2、自定义一个类(circular_queue.py)

# 定义队列类
class MyQueue(object):
    def __init__(self, size):
        self.size = size  # 定义队列长度
        self.queue = []  # 存储队列 列表

    def __str__(self):
        # 返回对象的字符串表达式，方便查看
        return str(self.queue)

    def inQueue(self, n):
        # 入队
        if self.isFull():
            return -1
        self.queue.append(n)  # 列表末尾添加新的对象

    def outQueue(self):
        # 出队
        if self.isEmpty():
            return -1
        firstelement = self.queue[0]   # 删除队头元素
        self.queue.remove(firstelement)  # 删除队操做
        return firstelement

    def delete(self, n):
        # 删除某元素
        element = self.queue[n]
        self.queue.remove(element)

    def inPut(self, n, m):
        # 插入某元素 n表明列表当前的第n位元素 m表明传入的值
        self.queue[n] = m

    def getSize(self):
        # 获取当前长度
        return len(self.queue)

    def getnumber(self, n):
        # 获取某个元素
        element = self.queue[n]
        return element

    def isEmpty(self):
        # 判断是否为空
        if len(self.queue) == 0:
            return True
        return False

    def isFull(self):
        # 判断队列是否满
        if len(self.queue) == self.size:
            return True
        return False

 

3、测试

在文件circular_queue.py中类的下头继续添加以下代码

queue = MyQueue(5)  # 定义一个大小为5的队列
for i in range(8):
    # 先判断队列是否为满
    if not queue.isFull():
        queue.inQueue(i)
    else:
        # 先出队再添加
        queue.outQueue()
        queue.inQueue(i)
    print(queue)

运行结果以下

　　能够看出已经实现了，固然你也能够试试其余几种方法，好比提取元素，获取队列大小等等。接下来就能够像操做列表对元素进行提取，而且不会删除元素。

for i in range(queue.getSize()):
    item =queue.getnumber(i)
    print(item)

 

　　固然也能够把circular_queue。py文件单独保存，而后到其余文件中引入，放入同一文件夹下，新建test.py，而后运行试试：

from circular_queue import *
import time


def fun2(num):
    num += 1
    return num


def fun1(num, res):
    while True:
        num = fun2(num)
        # 先判断队列是否为满
        if not queue.isFull():
            queue.inQueue([num, res])
        else:
            # 先出队再添加
            queue.outQueue()
            queue.inQueue([num, res])
        print(queue)
        time.sleep(2)


if __name__ == "__main__":
    queue = MyQueue(5)
    fun1(0, '-aaa-')