如何在线程中使用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()

它的脚本不正确的工作.我想要:

1) print 'test'
2) start 3 threads, waiting while all threads stops
3) sleep 2 seconds 
4) repeat

Answer 1

LoopingCall将运行您每隔N秒传递给它的可调用对象,其中N是您传递给它的数字.它在前一个呼叫完成后不等待N秒,它在前一个呼叫开始后等待N秒.换句话说,它试图保持在由N和开始时间定义的间隔,在N秒,N*2秒,N*3秒等处运行呼叫.

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

因此,您可以通过d在结束时返回来更接近您期望的行为loop,但是LoopingCall在延迟激发之后不会总是等待2秒.它将等待N秒的下一个倍数,从开始时间开始计数,然后再次调用该函数.