Как запустить виджет индикатора выполнения из dask.distributed в отдельном потоке?

Question

Приводится пример here, показывающий ввод данных для обработки в отдельном потоке. Меня интересует обратное, когда данные вставляются вручную и интерактивно, а фоновый поток отправляет их в кластер для вычисления.

Answer 1

Это уже тот случай. Когда вы звоните

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

Это сразу упорядочивает материал в локальном потоке (блокирования), а затем добавляет обратный вызов Торнадо IOLoop (работает в отдельном потоке) для управления фактической связи с планировщиком. Все это происходит асинхронно с основным потоком.