from threading import Thread
import time
from queue import Queue
q = Queue()
def run():
    while True:
        msg = q.get()
        print(msg)
        time.sleep(1)
        q.task_done()
 
 
for i in range(10):
    q.put(5-i)
 
for i in range(3):
    t = Thread(target=run)
    t.setDaemon(True)
    t.start()
q.join()

#-*-coding:utf-8-*-
import threading
import queue
import time
import random
 
'''
1.創(chuàng)建一個(gè) Queue.Queue() 的實(shí)例，然后使用數(shù)據(jù)對(duì)它進(jìn)行填充。
2.將經(jīng)過(guò)填充數(shù)據(jù)的實(shí)例傳遞給線程類，后者是通過(guò)繼承 threading.Thread 的方式創(chuàng)建的。
3.每次從隊(duì)列中取出一個(gè)項(xiàng)目，并使用該線程中的數(shù)據(jù)和 run 方法以執(zhí)行相應(yīng)的工作。
4.在完成這項(xiàng)工作之后，使用 queue.task_done() 函數(shù)向任務(wù)已經(jīng)完成的隊(duì)列發(fā)送一個(gè)信號(hào)。
5.對(duì)隊(duì)列執(zhí)行 join 操作，實(shí)際上意味著等到隊(duì)列為空，再退出主程序。
'''
 
class jdThread(threading.Thread):
    def __init__(self,index,queue):
        threading.Thread.__init__(self)
        self.index = index
        self.queue = queue
 
    def run(self):
        while True:
            time.sleep(1)
            item = self.queue.get(False,)
            if self.queue.empty():
                print("here")
                break
 
            print("序號(hào)：",self.index,"任務(wù)",item,"完成")
            self.queue.task_done()#task_done方法使得未完成的任務(wù)數(shù)量-1
 
if __name__ == '__main__':
 
    q = queue.Queue(0)
 
    for i in range(6):
        print ("the  i is :%d" % i)
        q.put(i)#put方法使得未完成的任務(wù)數(shù)量+1
 
    '''
    初始化函數(shù)接受一個(gè)數(shù)字來(lái)作為該隊(duì)列的容量，如果傳遞的是
    一個(gè)小于等于0的數(shù)，那么默認(rèn)會(huì)認(rèn)為該隊(duì)列的容量是無(wú)限的.
    '''
    for i in range(2):
        jdThread(i,q).start()#兩個(gè)線程同時(shí)完成任務(wù)
 
print ("I am here ")