Ejecutar una función periódicamente en el protocolo twisted

Probablemente quieras hacer esto en la fábrica para las conexiones. La Fábrica no se notifica automáticamente cada vez que se realiza una conexión y se pierde, por lo que puede notificarlo desde el Protocolo.

Aquí hay un ejemplo completo de cómo usar twisted.Internet.tarea.LoopingCall junto con una fábrica básica personalizada y un Protocolo para anunciar que 'han pasado 10 segundos' a cada conexión cada 10 segundos.

from twisted.internet import reactor, protocol, task

class MyProtocol(protocol.Protocol):
    def connectionMade(self):
        self.factory.clientConnectionMade(self)
    def connectionLost(self, reason):
        self.factory.clientConnectionLost(self)

class MyFactory(protocol.Factory):
    protocol = MyProtocol
    def __init__(self):
        self.clients = []
        self.lc = task.LoopingCall(self.announce)
        self.lc.start(10)

    def announce(self):
        for client in self.clients:
            client.transport.write("10 seconds has passed\n")

    def clientConnectionMade(self, client):
        self.clients.append(client)

    def clientConnectionLost(self, client):
        self.clients.remove(client)

myfactory = MyFactory()
reactor.listenTCP(9000, myfactory)
reactor.run()