lc.py

import time

from twisted.internet import reactor
from twisted.internet.task import LoopingCall
from twisted.python import log
from twisted.python.logfile import LogFile

log.startLogging(LogFile('lc.log', '.'))


def count_callable(calls):
    log.msg(format='***************** %(t)f calls:%(c)d',
            t=time.time(), c=calls)
    if calls != 1:
        log.msg('******************************************* anomaly')


def debug_lc(lc):
    log.msg(format="_expectNextCallAt %(x)f", x=lc._expectNextCallAt)
    log.msg(format="    _realLastTime %(x)f", x=lc._realLastTime)


lc = LoopingCall.withCount(count_callable)
lc.start(0.02)

lc_debug = LoopingCall(debug_lc, lc)
lc_debug.start(0.02)

reactor.run()