Как использовать LoopingCall с потоками? - PullRequest
Новая
       0

Как использовать LoopingCall с потоками?

3 голосов
/ 28 августа 2011

У меня есть простой пример: 

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

1 Ответ

5 голосов
/ 28 августа 2011

LoopingCall будет запускать вызываемый вами вызов каждые N секунд, где N - это номер, который вы передаете для запуска.Он не ожидает N секунд после завершения предыдущего вызова, он ожидает N секунд после начала предыдущего вызова.Другими словами, он пытается остаться в интервале, определяемом N и временем начала, выполняя вызов в N секунд, N * 2 секунд, N * 3 секунд и т. Д.

Если процесс слишком занятчтобы сделать один из вызовов, он пропустит эту итерацию.Если вызов возвращает Deferred и Deferred не сработал в следующем интервале, он пропустит эту итерацию.

Таким образом, вы можете приблизиться к желаемому поведению, вернув d в конце loop, но LoopingCall не собирается ждать 2 секунды после пожара Отложенного.Он будет ожидать следующего кратного N секунд, считая от времени начала, и затем снова вызовет функцию.

...