worker.py 文件源码

def run(self):
        self.context = zmq.Context()
        self.socket = self.context.socket(zmq.DEALER)
        self.socket.connect (self.controller_uri)
        self.stream = ZMQStream(self.socket)
        self.stream.on_recv(self.on_rcv)
        self.ioloop = ioloop.IOLoop.instance()
        self.ioloop.add_callback(self.on_start)
        tornado.ioloop.PeriodicCallback(self.on_ping, 1000).start()
        try:
            self.ioloop.start()
        except KeyboardInterrupt:
            self.shutdown()
        self.ioloop.close()