如何在单独的线程中运行dask.distributed的进度条小部件？

Question

有一个示例here，显示插入数据以在单独的线程中处理。当我手动和交互式地插入数据，并且后台线程将它们提交给群集进行计算时，我对此有兴趣。

Answer 1

这已经是这种情况。当你调用

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

这立即序列化的东西在本地线程（阻塞），但后来增加了一个回调到龙卷风IOLoop（在一个单独的线程中运行）来管理调度的实际通信。这一切都与主线程异步发生。