多线程应用-类（thread）

# -*- coding: UTF-8 -*-
from time import ctime,sleep
import threading,datetime
from Queue import Queue

class pdc(threading.Thread):
    def __init__(self,t_name):
        threading.Thread.__init__(self,name=t_name)
        #self.name=‘aaa‘ #此时self还不是Thread，为string格式
    def run(self): #run()方法继承于threading，需要重写定义自己的内容
        self.setName(‘b‘+str(i)) #self.setName(‘bbb‘) #此时self是Thread，可以通过 print dir(self) 查看所具有的属性/方法
        print ‘%s: %s is producing %d to the queue.‘ %(ctime(),self.getName(),i)
        sleep(1)

if __name__ == ‘__main__‘:
    threads=[]
    for i in range(5):
        t = pdc(‘p‘+str(i))
        t.start()
        threads.append(t)
    for t in threads:
        t.join()