快捷導(dǎo)航

python獲取多線程及子線程的返回值

更新時(shí)間：2017年11月15日 17:24:22 投稿：mrr

這篇文章主要介紹了python獲取多線程及子線程的返回值的相關(guān)資料,需要的朋友可以參考下

最近有個(gè)需求，用多線程比較合適，但是我需要每個(gè)線程的返回值，這就需要我在threading.Thread的基礎(chǔ)上進(jìn)行封裝

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方法，此處可能會(huì)報(bào)沒有self.result的錯(cuò)誤
  except Exception:
   return None
def foo(a,b,c):
 time.sleep(1)
 print a*2,b*2,c*2,
 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，不然主線程比子線程跑的快，會(huì)拿不到結(jié)果
 print t.get_result()
et = time.time()
print et - st

執(zhí)行結(jié)果

0 2 4 (0, 2, 4)
4 6 8 2 4 6 (2, 4, 6)
(4, 6, 8)
6 8 10 (6, 8, 10)
1.00200009346

元組中的結(jié)果是函數(shù)foo的返回值，至于結(jié)果為什么這么亂，我猜，是因?yàn)楦髯泳€程foo的print和主線程print get_result()一起搶占系統(tǒng)資源造成。

下面介紹下python獲得子線程的返回值，具體代碼如下所示：

import sys 
import threading 
import Queue 
q = Queue.Queue() 
def worker1(x, y): 
 func_name = sys._getframe().f_code.co_name 
 print "%s run ..." % func_name 
 q.put((x + y, func_name)) 
def worker2(x, y): 
 func_name = sys._getframe().f_code.co_name 
 print "%s run ...." % func_name 
 q.put((x - y, func_name)) 
if __name__ == '__main__': 
 result = list() 
 t1 = threading.Thread(target=worker1, name='thread1', args=(10, 5, )) 
 t2 = threading.Thread(target=worker2, name='thread2', args=(20, 1, )) 
 print '-' * 50 
 t1.start() 
 t2.start() 
 t1.join() 
 t2.join() 
 while not q.empty(): 
  result.append(q.get()) 
 for item in result: 
  if item[1] == worker1.__name__: 
   print "%s 's return value is : %s" % (item[1], item[0]) 
  elif item[1] == worker2.__name__: 
   print "%s 's return value is : %s" % (item[1], item[0])

這是目前最主流的獲取線程數(shù)據(jù)的方法。使用 Queue 庫創(chuàng)建隊(duì)列實(shí)例，用來儲(chǔ)存和傳遞線程間的數(shù)據(jù)。Python 的隊(duì)列是線程安全的，也就是說多個(gè)線程同時(shí)訪問一個(gè)隊(duì)列也不會(huì)有沖突。Python 隊(duì)列有三種 FIFO 先進(jìn)先出，F(xiàn)ILO 先進(jìn)后出（類似棧），優(yōu)先級(jí)隊(duì)列（由單獨(dú)的優(yōu)先級(jí)參數(shù)決定順序）。使用隊(duì)列可以實(shí)現(xiàn)簡(jiǎn)單生產(chǎn)者 – 消費(fèi)者模型

總結(jié)

以上所述是小編給大家介紹的python獲取多線程及子線程的返回值，希望對(duì)大家有所幫助，如果大家有任何疑問請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！

您可能感興趣的文章: