最近有個需求,用多線程比較合適,可是我須要每一個線程的返回值,這就須要我在threading.Thread的基礎上進行封裝多線程
import threading class MyThread(threading.Thread): def __init__(self,func,args=()): super(MyThread,self).__init__() self.func = func self.args = args def run(self): self.result = self.func(*self.args) def get_result(self): try: return self.result # 若是子線程不使用join方法,此處可能會報沒有self.result的錯誤 except Exception: return None def foo(a,b,c): time.sleep(1) return a*2,b*2,c*2 st = time.time() li = [] for i in xrange(4): t = MyThread(foo,args=(i,i+1,i+2)) li.append(t) t.start() for t in li: t.join() # 必定要join,否則主線程比子線程跑的快,會拿不到結果 print t.get_result() et = time.time() print et - st
執行結果app
(0, 2, 4)
(2, 4, 6)
(4, 6, 8)
(6, 8, 10)
1.00099992752spa