达斯多处理

我正在尝试运行以下代码。如果在shell中执行,则可以工作,但是如果作为宏(py macro.py)执行,则崩溃。请您告诉我怎么了。 谢谢

import os
import sys
import dask
from dask.distributed import Client

def inc(x):
    return x + 1

def add(x,y):
    return x + y

client = Client(n_workers=2,threads_per_worker=2,memory_limit='1GB')

a = client.submit(inc,10)
b = client.submit(inc,20)
print(a.result())
print(b.result())
ZXY199 回答:达斯多处理

这是运行用于创建进程的脚本的问题。您需要在Client块中创建if __name__ == "__main__":对象

有关更多信息,请参见where to put freeze_support() in a Python script?中的答案。

本文链接:https://www.f2er.com/3154964.html

大家都在问