task_and_coroutines.py 文件源码

def share_task(fun):
    def w(*a, **k):

        if fun.func_globals["__name__"] == "__main__":
            address = ('localhost', 9000)
            message = {"module": fun.func_globals["__file__"].split("/")[-1].split(".")[0],
                       "method": fun.__name__}
            sock = socket.socket(type=socket.SOCK_DGRAM)
            sock.connect(address)
            sock.send(json.dumps(message))
        return fun(*a, **k)
    return w