如何在單獨的線程中運行dask.distributed的進度條小部件？

Question

有一個示例here，顯示插入數據以在單獨的線程中處理。當我手動和交互式地插入數據，並且後臺線程將它們提交給羣集進行計算時，我對此有興趣。

Answer 1

這已經是這種情況。當你調用

client.submit(function, *args, **kwargs) 

這立即序列化的東西在本地線程（阻塞），但後來增加了一個回調到龍捲風IOLoop（在一個單獨的線程中運行）來管理調度的實際通信。這一切都與主線程異步發生。