Python扭曲：如何调度？

在 Twisted 中有 1 天的经验，我尝试安排消息发送以回复 tcp 客户端：

import os, sys, time
from twisted.internet import protocol, reactor

self.scenario = [(1, "Message after 1 sec!"), (4, "This after 4 secs"), (2, "End final after 2 secs")]
for timeout, data in self.scenario:
        reactor.callLater(timeout, self.sendata, data)
        print "waited %d time, sent %s\n"%(timeout, data)

现在它发送消息，但我有两个问题：
1）“超时”是从“现在”开始的，我想在之前的每个任务完成后（发送之前的消息）进行计数
2）我不知道如何在发送所有消息后关闭连接。如果我放置self.transport.loseConnection() after callLater它会立即关闭连接。

在之前的尝试中我没有使用reactor.callLater， 但只有self.transport.write() and time.sleep(n) in for环形。在这种情况下，所有消息都在所有超时过去后一起发送......这不是我想要的。
目的是等待客户端连接，等待超时1并发送消息1，等待超时2并发送消息2，...等等。在最终消息之后 - 关闭连接。

使用 Twisted 时要认识到的重要一点是没有什么等待。你打电话时reactor.callLater()，你要求反应堆调用一些东西later， 现在不要。通话立即结束（安排通话后，before它已被执行。）因此，你的print声明是谎言：你没有等待timeout时间;你根本就没有等。

您可以通过多种方式修复它，使用哪种方式取决于您的实际需要。如果您希望第二个任务在第一个任务四秒后开始started，您可以简单地添加延迟（您的timeout第一个任务的变量）到第二个任务的延迟。不过，第一个任务可能不会在您安排的时间准确开始；如果 Twisted 太忙而无法早点开始，则可能会稍后开始。此外，如果您的任务需要很长时间，则在第二个任务开始之前实际上可能尚未完成。

更常见的方式是第一个任务调度第二个任务，而不是立即调度第二个任务。您可以在第一个任务结束后四秒安排它（通过调用reactor.callLater()在第一个任务结束时），或第一个任务开始后四秒（通过调用reactor.callLater() at the start第一个任务的时间），或者执行更复杂的计算来确定何时开始，并跟踪经过的时间。

当您意识到 Twisted 等待中没有任何内容时，在执行完所有计划任务后关闭连接就变得很容易：您只需调用最后一个任务即可self.transport.loseConnection()。对于更复杂的情况，您可能需要链接Deferred在一起，或使用DeferredList执行loseConnection()当所有挂起的任务完成时，即使它们不是严格顺序的。