做网站客户要先看效果后付款,专业轻电商网站建设公司,网站可以用cdr做吗,重庆做网站的网络公司创建一个“队列”对象import Queuemyqueue Queue.Queue(maxsize 10)Queue.Queue类即是一个队列的同步实现。队列长度可为无限或者有限。可通过Queue的构造函数的可选参数maxsize来设定队列长度。如果maxsize小于1就表示队列长度无限。将一个值放入队列中myqueue.put(10)调用队…创建一个“队列”对象import Queuemyqueue Queue.Queue(maxsize 10)Queue.Queue类即是一个队列的同步实现。队列长度可为无限或者有限。可通过Queue的构造函数的可选参数maxsize来设定队列长度。如果maxsize小于1就表示队列长度无限。将一个值放入队列中myqueue.put(10)调用队列对象的put()方法在队尾插入一个项目。put()有两个参数第一个item为必需的为插入项目的值第二个block为可选参数默认为1。如果队列当前为空且block为1put()方法就使调用线程暂停,直到空出一个数据单元。如果block为0put方法将引发Full异常。将一个值从队列中取出myqueue.get()调用队列对象的get()方法从队头删除并返回一个项目。可选参数为block默认为True。如果队列为空且block为Trueget()就使调用线程暂停直至有项目可用。如果队列为空且block为False队列将引发Empty异常。python queue模块有三种队列:1、python queue模块的FIFO队列先进先出。2、LIFO类似于堆。即先进后出。3、还有一种是优先级队列级别越低越先出来。针对这三种队列分别有三个构造函数:1、class Queue.Queue(maxsize) FIFO2、class Queue.LifoQueue(maxsize) LIFO3、class Queue.PriorityQueue(maxsize) 优先级队列介绍一下此包中的常用方法:Queue.qsize() 返回队列的大小Queue.empty() 如果队列为空返回True,反之FalseQueue.full() 如果队列满了返回True,反之FalseQueue.full 与 maxsize 大小对应Queue.get([block[, timeout]])获取队列timeout等待时间Queue.get_nowait() 相当Queue.get(False)非阻塞 Queue.put(item) 写入队列timeout等待时间Queue.put_nowait(item) 相当Queue.put(item, False)Queue.task_done() 在完成一项工作之后Queue.task_done()函数向任务已经完成的队列发送一个信号Queue.join() 实际上意味着等到队列为空再执行别的操作附上一个例子:#coding:utf-8import Queueimport threadingimport timeimport randomq Queue.Queue(0) #当有多个线程共享一个东西的时候就可以用它了NUM_WORKERS 3class MyThread(threading.Thread):def __init__(self,input,worktype):self._jobq inputself._work_type worktypethreading.Thread.__init__(self)def run(self):while True:if self._jobq.qsize() 0:self._process_job(self._jobq.get(),self._work_type)else:breakdef _process_job(self, job, worktype):doJob(job,worktype)def doJob(job, worktype):time.sleep(random.random() * 3)printdoing,job, worktype ,worktypeif __name__ __main__:print begin....for i inrange(NUM_WORKERS * 2):q.put(i) #放入到任务队列中去print job qsize:,q.qsize()for x inrange(NUM_WORKERS):MyThread(q,x).start()一些需要注意的地方1. 阻塞模式importQueueq Queue.Queue(10)......fori in range(10):q.put(A)time.sleep(0.5)这是一段极其简单的代码(另有两个线程也在操作队列q)我期望每隔0.5秒写一个A到队列中但总是不能如愿间隔时间有时会远远超过0.5秒。原来Queue.put()默认有 block True 和 timeou 两个参数。当 block True 时写入是阻塞式的阻塞时间由 timeou 确定。当队列q被(其他线程)写满后这段代码就会阻塞直至其他线程取走数据。Queue.put()方法加上 blockFalse 的参数即可解决这个隐蔽的问题。但要注意非阻塞方式写队列当队列满时会抛出 exception Queue.Full 的异常。2. 无法捕获 exception Queue.Empty 的异常whileTrue:......try:data q.get()exceptQueue.Empty:break我的本意是用队列为空时退出循环但实际运行起来却陷入了死循环。这个问题和上面有点类似Queue.get()默认的也是阻塞方式读取数据队列为空时不会抛出 except Queue.Empty 而是进入阻塞直至超时。 加上blockFalse 的参数问题迎刃而解。
