dask的futures
时间: 2023-09-02 08:10:46 浏览: 232
futures
Dask是一个用于并行计算的Python库,它提供了一种方便的方式来处理大规模数据集和复杂计算任务。在Dask中,futures是一种用于表示异步计算结果的对象。通过使用futures,我们可以在计算过程中异步地执行任务,并在需要时获取计算结果。
在Dask中,futures可以通过使用promises来创建。promise是一种表示未来计算结果的对象,它与future对象相关联。根据promise的实现方式,可能会出现p.future等于p的情况,即promise对象和future对象是相等的。\[1\]
使用futures,我们可以通过组合不同的操作来构建复杂的计算流程。在Dask中,futures的组合子是纯函数式的,每个组合子都返回一个与其来源future相关的新的future对象。这些组合子可以用于实现各种计算操作,如映射、过滤、聚合等。\[3\]
总结来说,Dask的futures是一种用于表示异步计算结果的对象,可以通过promises来创建。通过组合不同的操作,我们可以构建复杂的计算流程,并使用futures来获取计算结果。
#### 引用[.reference_title]
- *1* *2* *3* [scala Futures and Promises](https://blog.csdn.net/weixin_30797199/article/details/97672624)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^control_2,239^v3^insert_chatgpt"}} ] [.reference_item]
[ .reference_list ]
阅读全文