#!/usr/bin/env python# -*- coding:utf-8 -*-# author: Changhua Gongimport queuefrom queue import Queue'''class queue.Queue(maxsize=0) #先入先出class queue.LifoQueue(maxsize=0) #last in fisrt out class queue.PriorityQueue(maxsize=0) #存储数据时可设置优先级的队列方法：Queue.qsize()Queue.empty() #return True if empty  Queue.full() # return True if full Queue.put(item, block=True, timeout=None)Queue.put_nowait(item) Equivalent to put(item, False).Queue.get(block=True, timeout=None)Queue.get_nowait() Equivalent to get(False).Queue.task_done()Two methods are offered to support tracking whether enqueued tasks have been fully processed by daemon consumer threads.有两个方法用来跟踪消费线程中处理的对列任务是否被完全处理Queue.task_done()Indicate that a formerly enqueued task is complete.Used by queue consumer threads. For each get() used to fetch a task, a subsequent call to task_done() tells the queue that the processing on the task is complete.Queue.task_done()表明当前对列任务完成，对于每个get方法获取一个任务，后来对task_done方法的调用告诉对列这个任务处理完毕。If a join() is currently blocking, it will resume when all items have been processed (meaning that a task_done() call was received for every item that had been put() into the queue).如果join方法正在阻塞，所有的items会被继续处理完成，意味着对列中的每个item都会收到task_done()的通知Raises a ValueError if called more times than there were items placed in the queue.Blocks until all items in the Queue have been gotten and processed.Queue.join() block直到queue被消费完毕The count of unfinished tasks goes up whenever an item is added to thequeue. The count goes down whenever a consumer thread calls task_done()to indicate the item was retrieved and all work on it is complete.When the count of unfinished tasks drops to zero, join() unblocks.当未完成的任务数量下降至0时，join不再阻塞'''import threadingimport queuedef producer():    for i in range(10):        q.put("骨头 %s" % i)    print("开始等待所有的骨头被取走...")    q.join()    print("所有的骨头被取完了...")def consumer(n):    while q.qsize() > 0:        print("%s 取到" % n, q.get())        q.task_done()  # 告知这个任务执行完了q = queue.Queue()p = threading.Thread(target=producer, )p.start()consumer("李闯")print("****************************************************************")import time,randomimport queue,threadingq = queue.Queue()def Producer(name):  count = 0  while count <20:    time.sleep(random.randrange(3))    q.put(count)    print('Producer %s has produced %s baozi..' %(name, count))    count +=1def Consumer(name):  count = 0  while count <20:    time.sleep(random.randrange(4))    if not q.empty():        data = q.get()        print(data)        print('\033[32;1mConsumer %s has eat %s baozi...\033[0m' %(name, data))    else:        print("-----no baozi anymore----")    count +=1p1 = threading.Thread(target=Producer, args=('A',))c1 = threading.Thread(target=Consumer, args=('B',))p1.start()c1.start()

From: alex example