Результаты поиска по запросу "multiprocessing"
Многопроцессорная обработка Python никогда не включается
я используюmultiprocessingи конкретноPool раскрутить пару «ниток», чтобы выполнить кучу медленных заданий, которые у меня есть. Однако по какой-то причине я не могу заставить основной поток вернуться, хотя все дети, похоже, умерли. Решено: ...
Как разделить строку между несколькими процессами, используя Managers () в Python?
Мне нужно прочитать строки, написанные multiprocessing.Process экземпляры из основного процесса. Я уже использую менеджеры и очереди для передачи аргументов процессам, поэтому использование менеджеров кажется очевидным,но менеджеры ...
Использует defaultdict с многопроцессорностью?
Просто экспериментирую и учусь, и я знаю, как создать общий словарь, к которому можно получить доступ несколькими способами, но я не уверен, как сохранить синхронизацию.defaultdictПолагаю, иллюстрирует проблему, с которой я столкнулся. from ...
Как работает multiprocessing.Manager () в python?
У меня есть озабоченность по поводу многопроцессорности. Manager () в Python, вот пример, import multiprocessing def f(ns): ns.x *=10 ns.y *= 10 if __name__ == '__main__': manager = multiprocessing.Manager() ns = manager.Namespace() ns.x = 1 ...
python pool apply_async и map_async не блокируются в полной очереди
Я довольно новичок в питоне. Я использую модуль многопроцессорной обработки для чтения строк текста в stdin, преобразования их некоторым образом и записи в базу данных. Вот фрагмент моего кода: batch = [] pool = multiprocessing.Pool(20) i = 0 ...
Многопроцессорность на перерывах Windows
Я разрабатываю с Python на Linux и никогда не видел такого рода проблем с Windows. Я используюmultiprocessing библиотека для ускорения вычислений, которая очень хорошо работает для меня в Linux. Однако в Windows дела идут не так гладко: * ...
Как запустить несколько исполняемых файлов с помощью Python?
У меня есть исполняемый файл под Linux. У меня 8-ядерный процессор. Я хочу запустить 8 разных экземпляров одного и того же исполняемого файла с разными аргументами. Я пытался os.system("process_name args")Он не возвращается, пока процесс не ...
Совместное использование переменной между процессами
У меня есть функция загрузчика, которая загружает несколько файлов параллельно. я используюmultiprocessing.Pool.map_async для того, чтобы загрузить разные куски одного и того же файла. Я хотел бы показать строку состояния загрузки. Для этого мне ...
segfault использует lapack_lite от numpy с многопроцессорной обработкой на osx, а не на linux
Следующий тестовый код segfaults для меня на OSX 10.7.3, но не на других машинах: from __future__ import print_function import numpy as np import multiprocessing as mp import scipy.linalg def f(a): print("about to call") ### these all ...
Совместное использование очереди результатов между несколькими процессами
Документация дляmultiprocessing Модуль показывает, как передать очередь процессу, запущенному сmultiprocessing.Process, Но как я могу разделить очередь с асинхронными рабочими процессами, запущенными сapply_async? Мне не нужно динамическое ...