Вопросы по теме 'python-multiprocessing'

Многопроцессорность Python и сериализация данных
Я запускаю сценарий на школьном компьютере, используя модуль multiprocessing . Я часто сериализую данные. Это можно резюмировать кодом ниже: import multiprocessing as mp import time, pickle def simulation(j): data = [] for k in...
1519 просмотров
schedule 09.01.2023

Модуль многопроцессорности Python: объединение процессов с тайм-аутом
Я занимаюсь оптимизацией параметров сложной симуляции. Я использую многопроцессорный модуль для повышения производительности алгоритма оптимизации. Основы многопроцессорной обработки я изучил на http://pymotw.com/2/multiprocessing/basics.html ....
30274 просмотров
schedule 18.06.2022

Многопроцессорный пул apply_async
Я играю с многопроцессорностью и особенно с пулом. import multiprocessing import os import time results = [] def task(args): print "Start Process", os.getpid(), "with args", args, " timing", time.time( ) time.sleep(10) print "End...
3091 просмотров

Функции массовой записи PyMongo с многопроцессорностью и генераторами
PyMongo поддерживает генераторы для пакетной обработки с помощью sDB.insert(iter_something(converted)) . Функции массовой записи, которые выполняют операции записи в пакетах, чтобы уменьшить количество сетевых циклов и увеличить пропускную...
1123 просмотров

Пул процессов Python не создает ожидаемого количества процессов
Я пытаюсь написать простую программу, используя модуль пула Python. Вот мой код: from multiprocessing import Pool from multiprocessing.pool import ApplyResult import time import os def unwrap_self_f(arg, **kwarg): print 'inside unwrap_self_f'...
83 просмотров

Когда я использую метод соединения в многопроцессорном модуле?
Я изучаю модуль многопроцессорности. Я нашел эти примеры в документации на python.org: from multiprocessing import Process def f(name): print('hello', name) if __name__ == '__main__': p = Process(target=f, args=('bob',)) p.start()...
120 просмотров

Ошибка многопроцессорности Python с методами класса
Я пишу программу, в которой у меня есть объектно-ориентированный код, в котором я пытаюсь выполнять многопроцессорную обработку. Я получал ошибки рассола, потому что по умолчанию python может сериализовать функции, но не методы классов. Поэтому я...
1408 просмотров
schedule 11.06.2022

Многопроцессорное разделение задач
У меня есть две разные задачи, которые я хочу разделить между процессами. У меня есть одна задача, которая состоит из получения ответов с URL-адресов и записи ответов в Queue (многопроцессорная очередь, а не многопоточность), над которой я хотел...
73 просмотров

Создавайте новые TCP-соединения для каждого HTTP-запроса в python
Для моего проекта в колледже я пытаюсь разработать генератор трафика на основе Python. Я создал 2 машины CentOS на vmware, и я использую 1 в качестве моего клиента и 1 в качестве моей серверной машины. Я использовал метод псевдонимов IP, чтобы...
684 просмотров

Системная ошибка в многопроцессорной обработке
Я использую многопроцессорность для выполнения функции для итеративных аргументов. Для слишком длинных массивов в аргументе я получаю следующее сообщение об ошибке: <multiprocessing.pool.Pool object at 0x545912490> Exception in thread...
354 просмотров

Взаимоблокировки при использовании очередей и многопроцессорной обработки
Я не понимаю эту часть документа по многопроцессорности ( python.org ) и цитирую: «Пример, который приведет к тупику, следующий: from multiprocessing import Process, Queue def f(q): q.put('X' * 1000000) if __name__ == '__main__':...
485 просмотров

функция оценивается только тогда, когда она вызывается из приложения, но не когда она вызывается из apply_async
Я прочитал process-or-pool-for- что я делаю и когда использовать-применить-применить-асинхронную-или-карту , и я надеялся, что понимаю разницу между apply и apply_async . Но у меня есть этот код, который возвращает желаемый результат только...
219 просмотров

Одновременное чтение массивов numpy параллельно
Рассмотрим следующее: fine = np.random.uniform(0,100,10) fine[fine<20] = 0 # introduce some intermittency coarse = np.sum(fine.reshape(-1,2),axis=1) fine — это временной ряд величин (например, количество осадков). coarse — это тот же...
666 просмотров

Многопроцессорные процессы в состоянии непрерывного сна (D) при запуске из iPython Notebook
Я выполняю большое параллельное вычисление сопоставления из ноутбука iPython. Я сопоставляю кадр данных по предмету и условию с функцией прогнозирования машинного обучения, и я хочу, чтобы каждый предмет и условие были распределены между 20 ядрами....
919 просмотров

_multiprocessing.SemLock не реализован при работе на AWS Lambda
У меня есть короткий код, который использует пакет multiprocessing и отлично работает на моем локальном компьютере. Когда я загрузил на AWS Lambda и запустил там, я получил следующую ошибку (stacktrace обрезан): [Errno 38] Function not...
9117 просмотров
schedule 25.05.2023

scikit Learn LatentDirichletAllocation зависает после многопроцессорных и URL-запросов
Как правило, мой код Python выполняет следующие три шага. запустить multiprocess, чтобы очистить результаты поиска от поисковой системы очищать текст с каждого URL-адреса в списке (без многопроцессорности), используя библиотеку запросов python...
142 просмотров

Поведение многопроцессорной очереди Python
У меня есть этот код: def f(x, y): def _f(x, y, queue): res = get_data(x, y) queue.put(res) q = Queue() p = Process(target=_f, args=(x, y, q)) p.start() res = q.get() p.join() return res Это...
636 просмотров
schedule 19.07.2023

Python 2 для Python 3: не удается заставить работать многопроцессорность
Я перемещаю свой код с python 2.7 на python 3.5 и не могу заставить работать мой многопроцессорный код, что-то вроде следующего кода. "somemodule.py" в том же каталоге, что и основной скрипт . import multiprocessing as mp # somemodule is in the...
1627 просмотров

Будет ли уничтожение скрипта Python, вызывающего процессы оболочки, также убивать процессы оболочки?
Если у меня есть такой код в файле this_script.py: import subprocess subprocess.Popen(["python", "another_script.py"]) и я звоню python this_script.py и убить процесс во время его работы, убьет ли он подпроцесс? Изменить: я...
246 просмотров

модуль многопроцессорности python: странное поведение и загрузка процессора при использовании пула
Я использую многопроцессорную библиотеку Python, чтобы ускорить некоторый код (метод наименьших квадратов, соответствующий scipy). Он отлично работает на 3-х разных машинах, но показывает странное поведение на 4-й машине. Код: import numpy...
675 просмотров