Python线程下queue（队列）模块的用法（附实例）

from threading import Thread

from queue import Queue

class WorkerThread(Thread):

    def __init__(self,*args,**kwargs):

        Thread.__init__(self,*args,**kwargs)

        self.input_queue=Queue()

    def send(self,item):

        self.input_queue.put(item)

    def close(self):

        self.input_queue.put(None)

        self.input_queue.join()

    def run(self):

        while True:

            item=self.input_queue.get()

            if item is None:

                break

            #实际开发中，此处应该使用有用的工作代替

            print(item)

            self.input_queue.task_done()

        #完成，指示收到和返回哨兵

        self.input_queue.task_done()

        return

if __name__=="__main__":

    w=WorkerThread()

    w.start()

    w.send("php")

    w.send("中")

    w.send("文")

    w.send("网")

    w.close()

php

中

文

网