如何在单独的线程中从 dask.distributed 运行 进度条小部件？
How to run progress bar widget from dask.distributed in a separate thread?
有一个示例 here，显示插入数据以在单独的线程中处理。我对反向感兴趣，当数据被手动和交互式插入时，后台线程将它们提交给集群进行计算。
已经是这样了。当你打电话给
client.submit(function, *args, **kwargs)
这会立即在本地线程中序列化内容（阻塞），然后向 Tornado IOLoop 添加回调（运行 在单独的线程中）以管理与调度程序的实际通信。这一切都与主线程异步发生。
有一个示例 here，显示插入数据以在单独的线程中处理。我对反向感兴趣，当数据被手动和交互式插入时，后台线程将它们提交给集群进行计算。
已经是这样了。当你打电话给
client.submit(function, *args, **kwargs)
这会立即在本地线程中序列化内容（阻塞），然后向 Tornado IOLoop 添加回调（运行 在单独的线程中）以管理与调度程序的实际通信。这一切都与主线程异步发生。