扭曲的线程......如何正确使用它们？

Question

我需要编写一个运行两个线程的简单应用程序： - 线程 1：定时运行，假设每 1 分钟运行一次 - 线程 2：只是一个“正常”的 while True 循环，它做“东西”

如果不是按时间间隔运行的要求，我根本不会看扭曲，但简单的 sleep(60) 还不够好，结构如下：

l = task.LoopingCall(timed_thread)
l.start(60.0)
reactor.run()

在那里实现我想要的看起来真的很简单。

现在，我如何“正确”添加另一个线程？

我在这里看到两个选项：

• 使用线程库并运行两个“python 线程”，一个执行我的 while 循环，另一个运行 reactor.run()。但谷歌似乎反对这种做法，并建议使用扭曲线程
• 使用绞线。这就是我尝试过的方法，但不知何故这对我来说有点笨拙。

这是我想出的：

def timed_thread():
    print 'i will be called every 1 minute'
    return

def normal_thread():
    print 'this is a normal thread'
    time.sleep(30)
    return

l = task.LoopingCall(timed_thread)
l.start(60.0)
reactor.callInThread(normal_thread)
reactor.run()

这似乎可行，但是！我无法停止应用程序。如果我按下 ^C，它不会做任何事情（没有'callInThread'，它会像你期望的那样停止）。 ^Z 轰炸到 shell，如果我然后执行 'kill %1' 它似乎会杀死进程（shell 报告），但 'normal' 线程继续运行。 kill PID 不会摆脱它，唯一的治疗方法是 kill -9。真奇怪。

所以。我究竟做错了什么？在扭曲中实现两个线程是正确的方法吗？我不应该为扭曲而烦恼吗？还有哪些其他“标准”替代方案可以实现定时呼叫？ （'标准'我的意思是我可以 easy_install 或 yum 安装它们，我不想开始从随机网页下载和使用一些随机脚本）。

Answer 1

假设你的 main 是相对非阻塞的：

import random
from twisted.internet import task

class MyProcess:
  def __init__(self):
    self.stats = []
    self.lp = None
  def myloopingCall(self):
    print "I have %s stats" % len(self.stats)
  def myMainFunction(self,reactor):
    self.stats.append(random.random())
    reactor.callLater(0,self.myMainFunction,reactor)
  def start(self,reactor):
    self.lp = task.LoopingCall(self.myloopingCall)
    self.lp.start(2)
    reactor.callLater(0,self.myMainFunction,reactor)
  def stop(self):
    if self.lp is not None:
      self.lp.stop()
    print "I'm done"

if __name__ == '__main__':
  myproc = MyProcess()
  from twisted.internet import reactor
  reactor.callWhenRunning(myproc.start,reactor)
  reactor.addSystemEventTrigger('during','shutdown',myproc.stop)
  reactor.callLater(10,reactor.stop)
  reactor.run()

$蟒蛇bleh.py 我有 0 个统计数据 我有 33375 个统计数据 我有 66786 个统计数据 我有 100254 个统计数据 我有 133625 个统计数据 我受够了

Answer 2

您没有在这里解释为什么您实际上需要线程。如果你有，我也许可以解释为什么你不需要需要它们。 ;)

除此之外，我可以确认您对事物的基本理解是正确的。不过，我可以澄清的一个可能的误解是“python 线程”和“Twisted 线程”彼此完全不同的概念。他们不是。 Python 提供了一个线程库。 Twisted 的所有线程 API 都是根据 Python 的线程库实现的。只是 API 不同。

就关机而言，您有两种选择。

• 直接使用 Python 的线程 API 启动您的永远运行线程，并使该线程成为守护进程。即使守护线程仍在运行，您的进程也可以退出。此解决方案的一个可能问题是某些版本的 Python 存在守护线程问题，这将导致在关闭时崩溃。
• 使用 Twisted 的 API 或 stdlib 线程 API 创建您的线程，同时使用 reactor.addSystemEventTrigger('before', 'shutdown', f) 添加一个 Twisted 关闭挂钩。在那个钩子中，与工作线程通信并告诉它关闭。例如，您可以在 Twisted 线程和您的工作线程之间共享一个 threading.Event 并使用钩子 set 它。工作线程可以定期检查是否已设置，并在发现已设置时退出。除了不会崩溃之外，这与守护线程相比还有另一个优势 - 它可以让您在进程退出之前在工作线程中运行一些清理或终结代码。