Python多线程 简明例子

def worker(a_tid,a_account):
    global g_mutex
    print “Str ” , a_tid, datetime.datetime.now()
    for i in range(1000000):
        #g_mutex.acquire()
        a_account.deposite(1)
        #g_mutex.release() 
    print “End ” , a_tid , datetime.datetime.now()
    
class Account:
    def __init__ (self, a_base ):
        self.m_amount=a_base
    def deposite(self,a_amount):
        self.m_amount+=a_amount
    def withdraw(self,a_amount):
        self.m_amount-=a_amount    
        
if __name__ == “__main__”:
    global g_mutex
    count = 0
    dstart = datetime.datetime.now()
    print “Main Thread Start At: ” , dstart

    #init thread_pool
    thread_pool = []
    #init mutex
    g_mutex = threading.Lock()
    # init thread items
    acc = Account(100)
    for i in range(10):
        th = threading.Thread(target=worker,args=(i,acc) ) ;
        thread_pool.append(th)
        
    # start threads one by one        
    for i in range(10):
        thread_pool[i].start()
    
    #collect all threads
    for i in range(10):
        threading.Thread.join(thread_pool[i])
    dend = datetime.datetime.now()
    print “count=”,acc.m_amount
    print “Main Thread End at: ” ,dend , ” time span ” , dend-dstart;