如何对线程使用LoopingCall？

Question

我举一个简单的例子：

from twisted.internet import utils, reactor
from twisted.internet import defer
from twisted.internet import threads
from twisted.internet.task import LoopingCall,deferLater
import time

def test1():
    print 'test'

def test2(res):
       l = []
       for i in xrange(3):
           l.append(threads.deferToThread(test4))
       return defer.DeferredList(l)

def test3(res):
    pass

def test4():
    print 'thread start'
    time.sleep(10)
    print 'thread stop'


def loop():
    d = defer.maybeDeferred(test1)
    d = d.addCallback(test2)
    d.addCallback(test3)

LoopingCall(loop).start(2)

reactor.run()

这是剧本不正确的作品。我想：

^{pr2}$

Answer 1

LoopingCall将每隔N秒运行一次传递给它的可调用函数，其中N是传递给它的开始数字。它不会在前一个调用完成后等待N秒，而是在前一个调用开始后等待N秒。换句话说，它试图保持N和开始时间定义的间隔，在N秒、N*2秒、N*3秒等时间运行一个调用

如果进程太忙而无法进行其中一个调用，它将跳过该迭代。如果调用返回一个Deferred，并且Deferred在下一个时间间隔内没有触发，它将跳过该迭代。在

因此，您可以通过在loop结尾返回d来接近您所期望的行为，但是LoopingCall不会总是在延迟触发后等待2秒。它将等待下一个N秒的倍数（从开始时间算起），然后再次调用函数。在