Я пытаюсь отправить информацию, извлеченную из строк большого файла, процессу, работающему на каком-то сервере. Чтобы ускорить это, я хотел бы сделать это с несколькими потоками параллельно. Используя бэкпорт Python 2.7 для concurrent.futures ,...

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

У меня есть список dataframe_chunk , который содержит фрагменты очень большого фрейма данных pandas. Я хотел бы записать каждый фрагмент в другой CSV и сделать это параллельно. Однако я вижу, что файлы записываются последовательно, и я не уверен,...

Я изучаю фьючерсы в своем классе параллельного программирования. Мой профессор заявил об этом на своих слайдах: "Valid" futures are future objects associated to a  shared state, and are constructed by calling one of the following functions:...

Я пытаюсь распараллелить некоторый код Python, используя процессы и concurrent.futures . Похоже, я могу выполнять функцию несколько раз параллельно либо с помощью отправка вызовов и последующий вызов Future.result() на фьючерсах или с...

Я работаю над поисковым роботом, используя python, чтобы получить все абсолютные URL-адреса на веб-странице, а затем выполнить поисковый робот для каждого URL-адреса на этой веб-странице. например: Как мы видим, веб-страница...

Я использую Python concurrent.futures рамки. Я использовал функцию map() для запуска параллельных задач как таковых: def func(i): return i*i list = [1,2,3,4,5] async_executor = concurrent.futures.ThreadPoolExecutor(5) results =...

Я использую сервер Flask для обработки запросов на некоторые задачи обработки изображений. Обработка в значительной степени зависит от OpenCV, и теперь я хотел бы тривиально распараллелить некоторые из более медленных шагов. Я предпочитаю...

В документации NumPy по параллельному генерированию случайных чисел показано, как используйте SeedSequence для создания семян внуков (см. ниже). from numpy.random import SeedSequence, default_rng ss = SeedSequence(12345) # Spawn off 10...