反应堆停止的时间比我预期的要早？

Question

感谢本教程和许多其他教程，我正在尝试自学一些基本的 Twisted 编程。我已经看到这个当前的例子，我无法弄清楚它为什么要做它正在做的事情。

简短摘要：我已经实例化了三个反应器，它们从 5 倒数到 1，并具有不同的计数延迟。唯一的问题是，看起来当第一个计数器（延迟最短）达到 0 时，它不仅停止自己的反应堆，还停止所有其他反应堆。

#!/usr/bin/env python

class Countdown(object):

    counter = 5

    def count1(self):
        from twisted.internet import reactor
        if self.counter == 0:
            reactor.stop()
        else:
            print self.counter, '...1'
            self.counter -= 1
            reactor.callLater(1, self.count1)

    def count2(self):
        from twisted.internet import reactor
        if self.counter == 0:
            reactor.stop()
        else:
            print self.counter, '...2'
            self.counter -= 1
            reactor.callLater(0.5, self.count2)

    def count3(self):
        from twisted.internet import reactor
        if self.counter == 0:
            reactor.stop()
        else:
            print self.counter, '...3'
            self.counter -= 1
            reactor.callLater(0.25, self.count3)

from twisted.internet import reactor

reactor.callWhenRunning(Countdown().count1)
reactor.callWhenRunning(Countdown().count2)
reactor.callWhenRunning(Countdown().count3)

print 'Start!'
reactor.run()
print 'Stop!'

输出

Start!
5 ...1
5 ...2
5 ...3
4 ...3
4 ...2
3 ...3
2 ...3
4 ...1
3 ...2
1 ...3
Stop!

我的印象是，虽然所有三个计数器都应该以自己的速度倒数并完成其 5->0 进程，但程序会等待它们全部完成后再退出。我是否误解了 Twisted 的某些方式？

Answer 1

我不熟悉扭曲，但从浏览谷歌结果来看，反应堆似乎是一个事件循环。您只有其中一个，因此第一个命中reactor.stop()的计​​数器会停止循环。

要执行您想要的操作，您需要删除reactor.stop()调用并构造事物，以便当最后一个计时器到达末尾时，只有它调用reactor.stop()

Answer 2

他在第 3 部分中对此进行了一些讨论。您可能会混淆“在一台服务器中启动三个反应器”和“启动三个不同的服务器”。这些例子建议采取后者；您的代码正在尝试执行前者。

基本上，反应器是一个单例，一旦停止就无法重新启动。所以每个进程只能有一个，或者每个线程只能有一个。

您不想启动三个反应器，而是希望在同一个反应器上设置三个不同的定时回调。他们都会在适当的时候被解雇。