dask 计算中的默认工作人员数量是多少？

Question

@delayed

def do_something():

    # Does some work

    pass

futures = [do_something() for x in range(100)]

compute(*futures)

工人的默认数量是否取决于我们的 CPU 内核？或者它是否并行运行所有 100 个（我认为不是这种情况）

但它如何使默认工作人员计数？

Answer 1

根据dask 网站，正如您所建议的那样，它默认为内核数。