concurrent.futures

0зной

1ответ

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

1зной

1ответ

нажатие упакованной задачи в контейнер вызывает ошибку C2280 в VS2013

Я хочу использовать packaged_tasks для добавления задач в контейнер. Я создаю задачу, привязываю ее к числу и пытаюсь подтолкнуть ее к моему деку. Я получаю ошибку компилятора C2280 (VS2013) на push_b

2зной

1ответ

Python concurrent.futures с использованием подпроцесса с обратным вызовом

Я выполняю exe из FORTAN из Python. FORTRAN exe занимает много минут, чтобы закончить; поэтому, когда exe заканчивается, мне нужно вызвать обратный вызов. Exe ничего не возвращает на Python, но в функ

2зной

1ответ

Как я могу отменить зависающую асинхронную задачу в торнадо с тайм-аутом?

Моя установка - сервер торнадо python, который асинхронно обрабатывает задачи с помощью ThreadPoolExecutor. В некоторых условиях задача может превратиться в бесконечный цикл. С помощью декоратора with

20зной

1ответ

Как вы убиваете фьючерсы после их запуска?

Я использую новый модуль concurrent.futures (который также имеет Python 2 backport), чтобы сделать несколько простых многопоточных операций ввода-вывода. У меня возникли проблемы с пониманием того, ка

0зной

1ответ

Tornado Будущий объект отправляется в Редис и грузы из Redis

Я разрабатывал систему Push с торнадо. Поскольку я беру длительный опрос, мне нужно сохранить список Future Object, чтобы позже установить результаты для них. Затем я хочу сохранить список Future в Re

1зной

1ответ

Python Concurrent.Futures Карта не выполняется одновременно

У меня есть следующий пример: import time import concurrent.futures x = [10, 1, 2] def sleeper(secs): time.sleep(secs) print('I slept for {} seconds'.format(secs)) # returns in the ord