從線程收益項目

Question

from threading import Thread 
import time 
print 'start of script' 

class MyThread(Thread): 
    def __init__(self, start, end): 
     self.start = start 
     self.end = end 
    def run(self): 
     for i in xrange(self.start,self.end): 
      yield i 




my_threads = [] 

my_thread = MyThread(1,6) 
my_thread.start() 
my_threads.append(my_thread) 

my_thread = MyThread(6,11) 
my_thread.start() 
my_threads.append(my_thread) 

my_thread = MyThread(11,16) 
my_thread.start() 
my_threads.append(my_thread) 


for t in my_threads: 
    print t.join() 

print 'end of script' 

如何正確執行此操作？ 我試圖打印的數字：範圍（1,16），其中我從一個函數的輸出得到這個數字運行在一個單獨的線程。

我明白，我不會得到這個範圍數字按順序排列，就像在單獨的線程中運行的函數的性質一樣

我也知道我可以簡單地在線程的函數本身中打印它們，但那不是重點，我想打印我已經輸出的東西在我的代碼的主線程或主要部分。

Answer 1

我認爲你要找的是一個Queue。將一個隊列傳遞到你的線程，然後不是產生值，而是將它們放入隊列中myqueue.put(i)）。然後你可以在主線程中獲得它們（myqueue.get()）。

Answer 2

線程不會返回值，所以您將無法按照您的希望將值返回給主線程。如果你想讓你的腳本運行（你需要將你的start變量的名稱改爲別的，因爲你隱藏了start方法），你會發現t.join()的返回值是None。解決此問題的常見方法是使用一個隊列，在這個類似的問題被提出：Return value from thread

在你的情況，而不是調用yield i我會打電話queue.put(i)其中queue是在Queue.Queue建設過程中傳遞的，然後有一個循環投擲Empty並打破while循環的前

while True: 
    try: 
     print outqueue.get(True, 1) 
    except Empty: 
     break 

for t in my_threads: 
    print t.join() 

這將等待1秒一個新項目：在主線程之前，我加入了我的線程。