目录
一、何谓队列
二、队列抽象数据类型
三、用Python实现队列
四、模拟:传土豆
五、模拟:打印任务
5.1 主要模拟步骤
5.2 Python实现
一、何谓队列
队列是有序集合,添加操作发生在“尾部”,移除操作则发生在“头部”。新元素从尾部进入队列,然后一直向前移动到头部,直到成为下一个被移除的元素。
最新添加的元素必须在队列尾部等待,在队列中时间最长的元素则排在最前面。这种排序原则被称作FIFO,即先进先出,也称先到先得。
二、队列抽象数据类型
队列抽象数据类型由下面的结构和操作定义。如前所述,队列是元素的有序集合,添加操作发生在其尾部,移除操作则发生在头部。队列的操作顺序是FIFO,它支持以下操作。
- Queue()创建一个空队列。它不需要参数,且会返回一个空队列。
- enqueue(item)在队列的尾部添加一个元素。它需要一个元素作为参数,不返回任何值。
- dequeue()从队列的头部移除一个元素。它不需要参数,且会返回一个元素,并修改队列的内容。
- isEmpty()检查队列是否为空。它不需要参数,且会返回一个布尔值。
- size()返回队列中元素的数目。它不需要参数,且会返回一个整数。
在“队列内容”一列中,队列的头部位于右端。
三、用Python实现队列
需要确定列表的哪一端是队列的尾部,哪一端是头部。假设队列的尾部在列表的位置0处。如此一来,便可以使用insert函数向队列为尾部添加新元素。pop则可用于移除队列头部的元素(列表中的最后一个元素)。这意味着添加操作的时间复杂度是O(n),移除操作则是O(1)。
class Queue:
def __init__(self):
self.items=[]
def isEmpty(self):
return self.items==[]
def enqueue(self,item):
self.items.insert(0,item)
def dequeue(self):
return self.items.pop()
def size(self):
return len(self.items)
q=Queue()
print(q.isEmpty())
q.enqueue('dog')
q.enqueue(4)
q=Queue()
print(q.isEmpty())
q.enqueue(4)
q.enqueue('dog')
q.enqueue(True)
print(q.size())
print(q.isEmpty())
q.enqueue(8.4)
print(q.dequeue())
print(q.dequeue())
print(q.size())
四、模拟:传土豆
展示队列用法的一个典型方法是模拟需要以FIFO方式管理数据的真实场景。考虑这样做一个儿童游戏:传土豆。在这个游戏中,孩子们围成一圈,并依次尽可能快地传递一个土豆。某个时刻,大家停止传递,此时手里有土豆的孩子就得退出游戏。重复上述过程,直到只剩下一个孩子。
我们将针对传土豆游戏实现通用的模拟程序。该程序接受一个名字列表和一个用于计数的常数num,并且返回最后一人的名字。
我们使用队列来模拟一个环。假设握着土豆的孩子位于队列的头部。在模拟传土豆的过程中,程序将孩子的名字移出队列,然后立刻将其插入队列的尾部。随后,这个孩子会一直等待,直到再次到达队列的头部。在出列和入列num次之后,此时位于队列头部的孩子出局,新一轮游戏开始。如此反复,直到队列中只剩下一个名字(队列的大小为1)。
from pythonds.basic import Queue
def hotpotato(namelist,num):
simqueue=Queue()
for name in namelist:
simqueue.enqueue(name)
while simqueue.size()>1:
for i in range(num):
simqueue.enqueue(simqueue.dequeue())
simqueue.dequeue()
return simqueue.dequeue()
print(hotpotato(["Bill","David","Susan","Jane","Kent","Brad"],7))
五、模拟:打印任务
考虑计算机实验室里的这样一个场景:在任何给定的一小时内,实验室里都有约10个学生。他们在这一小时内最多打印2次,并且打印的页数从1到20不等。实验室的打印机比较老旧,每分钟只能以低质量打印10页。可以将打印质量调高,但是这样做会导致打印机每分钟只能打印5页。降低打印速度可能导致学生等待过长时间。
可以通过构建一个实验室模型来解决该问题。我们需要学生、打印任务和打印机构建对象。当学生提交打印任务时,我们需要将它们加入等待列表中,该列表是打印机上的打印任务队列。当打印机执行完一个任务后,它会检查该队列,看看其中是否还有需要处理的任务。我们感兴趣的是学生平均需要等待多久才能拿到打印好的文章。这个时间等于打印任务在队列中的平均等待时间。
在模拟时,需要应用一些概率学知识。举例来说,学生打印的文章可能有1~20页。如果各页数出现的概率相等,那么打印任务的实际时长可以通过1~20的一个随机数来模拟。
如果实验室有10个学生,并且在一小时内每个人都打印两次,那么每小时平均就有20个打印任务。每小时20个任务相当于每180秒1个任务。
可以通过1~180的一个随机数来模拟每秒内产生打印任务的概率。如果随机数正好是180,那么就认为有一个打印任务被创建。注意,可能会出现多个任务接连被创建的情况,也可能很长一段时间内没有任务。
5.1 主要模拟步骤
(1)创建一个打印任务队列。每一个任务到来时都会有一个时间戳。一开始,队列是空的。
(2)针对每一秒(currentSecond),执行以下操作。
- 是否有新创建的打印任务?如果是,以currentSecond作为其时间戳并将该任务加入到队列中。
- 如果打印机空闲,并且有正在等待执行的任务,执行以下操作:
- 从队列中取出第一个任务并提交给打印机;
- 用currentSecond减去该任务的时间戳,以此计算其等待时间;
- 将该任务的等待时间存入一个列表,以备后用;
- 根据该任务的页数,计算执行时间。
- 打印机进行一秒的打印,同时从该任务的执行时间中减去一秒。
- 如果打印任务执行完毕,或者说任务需要的时间减为0,则说明打印机回到空闲状态。
(3)当模拟完成后,根据等待时间列表中的值计算平均等待时间。
5.2 Python实现
我们创建3个类:Printer、Task和PrintQueue。它们分别模拟打印机、打印任务和队列。
Printer类需要检查当前是否有待完成的任务。如果有,那么打印机就处于工作状态,并且其工作所需的时间可以通过要打印的页数来计算。其构造方法会初始化打印速度,即每分钟打印多少页。tick方法会减量计时,并且在执行任务之后将打印机设置成空闲状态。
class Printer:
def __init__(self,ppm):
self.pagerate=ppm
self.currentTask=None
self.timeRemaining=0
def tick(self):
if self.currentTask != None:
self.timeRemaining=self.timeRemaining-1
if self.timeRemaining<=0:
self.currentTask=None
def busy(self):
if self.currentTask!=None:
return True
else:
return False
def startNext(self,newtask):
self.currentTask=newtask
self.timeRemaining=newtask.getPages()*60/self.pagerate
Task类代表单个打印任务。当任务被创建时,随机数生成器会随机提供页数,取值范围是1~20.我们使用random模块中的randrange函数来生成随机数。
import random
class Task:
def __init__(self,time):
self.timestamp=time
self.pages=random.randrange(1,21)
def getStamp(self):
return self.timestamp
def getPages(self):
return self.pages
def waitTime(self,currenttime):
return currenttime-self.timestamp
主模拟程序实现了之前描述的算法。printQueue对象是队列抽象数据类型的实例。布尔辅助函数newPrintTask判断是否有新创建的打印任务。我们再一次使用random模块中的rangrange函数来生成随机数,不过这一次的取值范围是1~180.平均每180秒有一个打印任务。通过从随机数中选取180,可以模拟这个随机事件。该模拟程序允许设置总时间和打印机每分钟打印多少页。
class Printer:
def __init__(self, ppm):
self.pagerate = ppm
self.currentTask = None
self.timeRemaining = 0
def tick(self):
if self.currentTask != None:
self.timeRemaining = self.timeRemaining - 1
if self.timeRemaining <= 0:
self.currentTask = None
def busy(self):
if self.currentTask != None:
return True
else:
return False
def startNext(self, newtask):
self.currentTask = newtask
self.timeRemaining = newtask.getPages() * 60 / self.pagerate
import random
class Task:
def __init__(self, time):
self.timestamp = time
self.pages = random.randrange(1, 21)
def getStamp(self):
return self.timestamp
def getPages(self):
return self.pages
def waitTime(self, currenttime):
return currenttime - self.timestamp
from pythonds.basic import Queue
import random
def simulation(numSeconds,pagesPerMinute):
labprinter=Printer(pagesPerMinute)
printQueue=Queue()
waitingtimes=[]
for currentSecond in range(numSeconds):
if newPrintTask():
task=Task(currentSecond)
printQueue.enqueue(task)
if (not labprinter.busy()) and (not printQueue.isEmpty()):
nexttask=printQueue.dequeue()
waitingtimes.append(nexttask.waitTime(currentSecond))
labprinter.startNext(nexttask)
labprinter.tick()
averageWait=sum(waitingtimes)/len(waitingtimes)
print("Average Wait %6.2f secs %3d tasks remaining."%(averageWait,printQueue.size()))
def newPrintTask():
num=random.randrange(1,181)
if num==180:
return True
else:
return False
for i in range(10):
simulation(3600,5)