application.py 文件源码

def _receive_message(c, block=False):
    """Receive a message."""
    if isinstance(c, multiprocessing.queues.Queue):
        try:
            message = c.get(block=block)
        except queue.Empty:
            return None
    else:
        if not block and not c.poll():
            return None

        try:
            message = c.recv()
        except EOFError:
            return None

    return message