如何解决获取 Python 中所有 pid 工作器的概述
当下面的代码被执行
import ray
from functools import wraps
ray.init(ignore_reinit_error=True)
def func_print(func):
@wraps(func)
def deco(*args,**kwargs):
print(func.__name__)
keep_track.append(func.__name__)
return func(*args,**kwargs)
deco.attrib = func.__name__
return deco
@ray.remote
@func_print
def f0():
return 0
@func_print
def f1():
return 5
@func_print
def f2():
return 5
@ray.remote
@func_print
def f3():
return {f2() * f1()}
keep_track = []
ray.get([f3.remote(),f0.remote()])
输出是
(pid=32645) f3
(pid=32645) f2
(pid=32645) f1
(pid=32649) f0
在一个有数千个进程在 12 个内核上执行的进程中,如何让公共 pid 工作器显示在同一个 pid 上执行的所有函数彼此相邻,如下面所需的输出所示
预期输出:
(pid=32645) f3,f2,f1
(pid=32649) f0
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。