如何在自己的线程中运行并正确停止？

Question

我在我的应用程序中使用了 twisted 并在它自己的线程中运行它。像这样使用 twisted 效果很好，但它永远不会正确停止。

例子：

# Python 2.7.6
# Twisted==15.4.0

import time
import threading
from twisted.internet import reactor

print("starting reactor")
reactor_thread = threading.Thread(target=reactor.run,
                              kwargs={"installSignalHandlers": False})
reactor_thread.start()
print("reactor started")

time.sleep(1)

print("stopping reactor")
reactor.stop()
print("joining thread")
reactor_thread.join()
print("reactor stopped")  # <- never reached

输出：

starting reactor
reactor started
stopping reactor
joining thread

Answer 1

您应该使用Crochet。它为您在线程中运行反应器。

您还应该认真考虑重构您的应用程序以尊重 Twisted 的习惯用法。这样做将允许您的应用程序与其他 Twisted 应用程序组合并减轻您的维护负担。 （这样你就不必在线程中运行反应器了。）