Описание тега concurrent.futures
NoneConcurrent.futures - это модуль Python, который предоставляет высокоуровневый интерфейс для асинхронного выполнения вызываемых объектов.
0
ответов
Как реализовать Java-класс будущего для достижения параллелизма, чтобы вызвать сценарий оболочки для нескольких одновременных соединений
Я использую будущий класс Java для достижения параллельного программирования. Я вызываю сценарий оболочки, как показано ниже. Я вызываю функцию ниже из моего контроллера Java String NodeResult=restartNodes(HostName); В реализации контроллера будущег…
06 апр '15 в 09:06
0
ответов
Я пытаюсь использовать параллельные фьючерсы для потоков, но кажется, что некоторые фьючерсы не возвращаются, они продолжают работать бесконечно
def parallelize_task_by_thread(func, iterable, workers=4): with ThreadPoolExecutor(max_workers=workers) as executor: future_to_url = {executor.submit(func, i): i for i in iterable} result = [] for future in concurrent.futures.as_completed(future_to_…
05 авг '18 в 08:03
2
ответа
Может ли concurrent.futures.Future быть преобразован в asyncio.Future?
Я практикуюсь asyncio после написания многопоточного кода много лет. Заметил что-то, что мне кажется странным. Оба в asyncio И в concurrent E сть Future объект. from asyncio import Future from concurrent.futures import Future Угадай, у каждого своя …
08 янв '19 в 16:52
1
ответ
Проверка на `concurrent.futures.ThreadPoolExecutor`
У меня есть живой concurrent.futures.ThreadPoolExecutor, Я хочу проверить его статус. Я хочу знать, сколько потоков существует, сколько обрабатывает задачи и какие задачи, сколько свободно, и какие задачи находятся в очереди. Как я могу узнать эти в…
24 авг '14 в 17:10
1
ответ
Есть ли что-то в Python 2.7, сродни Go `time.Tick` или Netty`HashedWheelTimer`?
Я пишу много кода, который опирается на точные периодические вызовы методов. Я использовал Python futures библиотека для отправки вызовов в пул потоков среды выполнения и ожидания между вызовами в цикле: executor = ThreadPoolExecutor(max_workers=cpu…
25 окт '17 в 21:01
0
ответов
Почему параллельные фьючерсы медленнее, чем мой цикл?
Эй, ребята, я хочу ускорить мой код с помощью многопроцессорной обработки с использованием параллельных фьючерсов. Я написал некоторый код для проверки и понимания параллельного будущего и для моделирования моего случая. Но почему-то метод одновреме…
24 дек '18 в 22:40
2
ответа
Процесс Python не очищен для повторного использования
Процессы, не очищенные для повторного использования Всем привет, Я наткнулся на проблему с ProcessPoolExecutorтам, где процессы обращаются к данным, они не должны быть в состоянии. Позволь мне объяснить: У меня есть ситуация, похожая на приведенный …
21 июн '18 в 13:57
0
ответов
Делает concurrent.futures.Future.results() освобождает GIL вызывающего потока [Python 2.7]
При написании GRPC-сервера на python я хотел использовать несколько процессов, доступных на моей машине, для выполнения некоторых вычислительных работ. Для интенсивных вычислений я планирую использовать concurrent.futures.ProcessPoolExecutor в pytho…
11 окт '17 в 10:42
0
ответов
Параллельные фьючерсы: лучшие настройки для нескольких асинхронных запросов?
Я хочу оптимизировать скрипт, чтобы сделать как можно больше сетевых запросов. Я вижу max_workers может быть ограничено количеством ядер на машине. Означает ли это, что если этот скрипт выполняется на компьютере EC2, например, t2.2xlarge с 8 виртуал…
14 фев '18 в 23:47
1
ответ
Извлечь значение из AsyncEither - ScalaZ
Я новичок в ScalaZ и в Scala в целом, поэтому я столкнулся с проблемой ниже. Я написал несколько модульных тестов для своего приложения, и мне нужно извлечь значение фактического ответа. Можете ли вы подсказать, как я могу это сделать? Expected :Pay…
17 июл '18 в 08:31
1
ответ
Python current.futures импортирует библиотеки несколько раз (многократно выполняет код в верхней области)
Для следующего скрипта (python 3.6, windows anaconda) я заметил, что библиотеки импортируются столько раз, сколько было вызвано процессоров. А также print('Hello') также выполняются несколько раз. Я думал, что процессоры будут вызываться только для …
12 июн '18 в 23:10
1
ответ
В чем разница между асинхронностью concurrent.futures и асинхронностью запросов-фьючерсов в python?
Я использовал запрос-фьючерс для асинхронного захвата веб-страницы. И на моей машине многоядерность, поэтому я также хочу захватить много веб-сайтов одновременно, затем я пытаюсь использовать concurrent.futures, кажется, что concurrent.futures также…
26 июл '14 в 03:04
1
ответ
Как обернуть пользовательское будущее для использования с Asyncio в Python?
Есть много библиотек, которые используют свои собственные версии Future. kafka и s3transfer - всего лишь два примера: все их пользовательские классы будущего object как суперкласс. Не удивительно, что вы не можете напрямую позвонить asyncio.wrap_fut…
18 мар '18 в 16:38
1
ответ
Использование `concurrent.futures.Future` в качестве обещания
В документации по Python я вижу: concurrent.futures.Future...... не должен создаваться напрямую, кроме как для тестирования. И я хочу использовать это как обещание в своем коде, и я очень удивлен, что не рекомендуется использовать его таким образом.…
10 ноя '14 в 08:02
0
ответов
boto3.s3.transfer - NoCredentialError при использовании пула потоков
У меня есть пользовательская библиотека передачи (TransLib), которая использует библиотеку boto3.s3.transfer для загрузки / выгрузки на s3. Когда я запускаю отдельные функции загрузки и выгрузки из моей библиотеки передачи (TransLib), это нормально.…
02 ноя '18 в 20:36
1
ответ
concurrent.futures: определить, какие будущие доходы
В последнее время я имею дело с concurrent.futures, я представил несколько функций в одном исполнителе, я хотел бы знать, какое будущее вернется первым. with concurrent.futures.ThreadPoolExecutor(max_workers=workers) as executor: future_action = exe…
07 июн '15 в 09:52
0
ответов
Параллельность в рекурсивной функции
У меня такая функция def jsonFlatten(obj: JsValue, coun: JsObject = Json.obj(), pref: String = ""): JsObject = { var con = coun var kel = "" var el: JsValue = Json.obj() obj match { case JsObject(_) => var ob = obj.validate[JsObject].get ob.value…
06 фев '15 в 07:09
1
ответ
Проверьте, происходит ли параллельное выполнение в Python
У меня есть следующий код, который использует селен, чтобы открыть 10 поисковых страниц Google и выполнить поиск по всем 10 поискам одновременно. Я думаю, что он работает правильно (параллельно), но я не уверен, потому что он на самом деле, кажется,…
11 мар '17 в 13:22
1
ответ
Python, вы можете передать функцию уровня модуля в ThreadPoolExecutor из класса
Я пытаюсь выполнить многопоточность в python, и я все еще пытаюсь разобраться с требованием к возможности выбора и насколько я могу сохранить свой код ООП. Можете ли вы запустить ThreadPoolExecutor из класса, передав ему функцию, определенную на уро…
05 янв '14 в 04:18
2
ответа
Python типирования и фьючерсы
Я очень рад использовать модуль ввода в Python 3. Кроме того, я очень рад использовать asyncio вместо twisted, tornado и альтернативы. Мой вопрос - как правильно определить результат сопрограммы? Должны ли мы сказать, что это просто сопрограмма? При…
15 июл '17 в 07:52