从线程收益项目

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秒一个新项目：在主线程之前，我加入了我的线程。