def METHOD_NAME(self):
    # if no timeout is given the worker will never wait and will
    # use the CPU for nothing. This minimal timeout prevent it.
    timeout = self.timeout or 0.5
    # self.socket appears to lose its blocking status after
    # we fork in the arbiter. Reset it here.
    for s in self.sockets:
        s.setblocking(0)
    if len(self.sockets) > 1:
        self.run_for_multiple(timeout)
    else:
        self.run_for_one(timeout)