8-2 如何线程间通信

# -*- coding: cp936 -*-

from threading import Thread
from Queue import Queue
from time import sleep

class DownThread(Thread):
    def __init__(self,sid,queue):
        #Thread.__init__(self)
        super(DownThread,self).__init__()
        self.sid = sid
        self.queue = queue

    def downLoad(self,sid):
        print("Download (%d)..." %sid)
        sleep(2)

    def run(self):
        self.downLoad(self.sid)
        data = self.sid+100
        self.queue.put((self.sid,data))

class ConvelThread(Thread):
    def __init__(self,queue):
        #Thread.__init__(self)
        super(ConvelThread,self).__init__()
        self.queue = queue

    def convel(self,sid,data):
        print("Convel  (%d)-(%d)" %(sid ,data))

    def run(self):
        while(True):
            sid, data = self.queue.get() #元组解包的形式得到数据
            if(sid == -1):    #当从队列读出-1时 线程退出结束
                break
            if(data):
                self.convel(sid,data)

q = Queue()

dThreads = [DownThread(i,q) for i in xrange(1,11)]

cThread = ConvelThread(q)

for t in dThreads:
    t.start()
    
cThread.start()
for t in dThreads:
    t.join()
    

q.put((-1,None))     #往队列中写入-1使 转换线程结束

cThread.join()

print(‘MainThread‘)