Dask多处理器

Question

我正在尝试运行以下代码。如果在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())

Answer 1

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

请参阅在Python脚本中放置freeze_support((的位置中的答案？了解更多信息。