调用函数时结束该线程的最佳方法是什么？

Question

我在使用这个队列时遇到了一些麻烦：

import Queue
import threading

class test(threading.Thread):

    def __init__(self):
        threading.Thread.__init__(self)
        self.request_queue = Queue.Queue()

    def addtoqueue(self, item):
        self.request_queue.put(item)

    def run(self):
        while True:
            item = self.request_queue.get(True)
            print item

这个简单的类实现了一个线程队列。调用 test::addtoqueue 会将一个项目追加到队列中。该线程等待一个项目被添加到队列中 - 并立即打印它并等待下一个项目。

我的问题是应用程序关闭。终止线程的最佳方法是什么？我可以使用条件，但如何等待来自条件的通知或队列中的新项目？

Answer 1

你可以向线程发送一些毒药来杀死它：

poison = None # something you wouldn't normally put in the Queue

class test(threading.Thread):

    def __init__(self):
        threading.Thread.__init__(self)
        self.request_queue = Queue.Queue()

    def kill(self):
        self.addtoqueue(poison)

    def addtoqueue(self, item):
        self.request_queue.put(item)

    def run(self):
        while True:
            item = self.request_queue.get(True)
            if item is poison:
                # do stuff
                return # end thread
            print item

Answer 2

我会改变 while 循环中的条件，以便它检查局部变量。添加终止开关以允许外部进程关闭线程。您可能应该扩展kill_me 以一种好的方式处理对象及其队列（例如，如果您想存储队列以供下次运行）。

编辑我还在其中添加了一个has_finished变量，因此kill_me应该阻止主进程线程。这应该允许线程在返回到主流程之前退出。

我可能把事情搞得太复杂了；）

class test(threading.Thread):

    def __init__(self):
        threading.Thread.__init__(self)
        self.request_queue = Queue.Queue()
        self.is_running = True
        self.has_finished = False   

    def addtoqueue(self, item):
        self.request_queue.put(item)

    def kill_me(self):
        self.is_running = False
        while not self.has_finished:
            pass

    def run(self):
        while self.is_running:
            item = self.request_queue.get(True)
            print item
        self.has_finished = True

Answer 3

做可能有效的最简单的事情 - 在这种情况下，可能是哨兵。尽管threading受到Java线程库的启发，但在Python中，最简单的事情不是像Java一样做事情并继承threading.Thread，而是传递一个函数及其threading.Thread() 的参数：

DONE = object() # Sentinel

def run(queue):
    while True:
        item = queue.get()
        queue.task_done()
        if item is DONE:
            break
        print item

request_queue = Queue.Queue()
some_thread = Thread(target=run, args=(request_queue,))

some_thread.start()

request_queue.put('hey')
request_queue.put('joe')
request_queue.put(DONE)