Я написал модуль расширения, который использует указатели функций C ++ для хранения последовательностей вызовов функций. Я хочу «запускать» эти последовательности вызовов в отдельных процессах, используя многопроцессорность python ...
Как лучше всего установить связь между двумя процессами в Python? После некоторого поиска в Google я попытался сделать это: parent_pipe, child_pipe = Pipe ()
p = Process (target = instance_tuple.instance ....
У меня есть программа, использующая многопроцессорность пакетов python и очередь. Одна из моих функций имеет такую структуру: из многопроцессорного импорта Process, Queue
def foo (queue): while True: try: ...
Я хочу динамически создавать несколько процессов, где каждый экземпляр имеет очередь для входящих сообщений от других экземпляров, и каждый экземпляр также может создавать новые экземпляры. Итак, мы получаем ...
Я только что обнаружил странную ошибку в моей программе, связанную с использованием модуля многопроцессорной обработки Python. Все работает нормально, когда я запускаю программу из исходного кода на своей машине. Но я строил ...
Большинство примеров многопроцессорных рабочих пулов выполняют одну функцию в разных процессах, например def foo (args): pass if __name__ == '__main__': pool = multiprocessing .Pool (process = 30) ...
Я пробую фрагмент кода из стандартной документации Python, чтобы узнать, как использовать модуль многопроцессорности. Код вставлен в конец этого сообщения.
Я использую Python 2.7.1 в Ubuntu 11 ....
На основе http://man7.org/tlpi/code/online/book/procexec/multi_SIGCHLD.c.html int
main (int argc, char * argv [])
{int j, sigCnt; sigset_t blockMask, emptyMask; struct sigaction sa; if (...
Похоже, что когда возникает исключение из процесса multiprocessing.Pool, нет трассировки стека или каких-либо других указаний на его сбой. Пример: from multiprocessing import Pool def go () ...
Я пытаюсь использовать очередь с библиотекой многопроцессорной обработки в Python. После выполнения приведенного ниже кода (операторы печати работают), но процессы не завершаются после того, как я вызываю join в очереди и там ...
У меня есть сценарий с именем jobrunner.py, который вызывает методы класса в main.py. См. Ниже ... # jobrunner.py
из многопроцессорного процесса импорта
основной импорт
from main import BBOX def _a (arg): f = main.a (...
на этот раз я столкнулся с проблемой «дизайна». Используя Python, у меня есть реализация математического алгоритма, который использует 5 параметров. Чтобы найти лучшую комбинацию этих 5 параметров, я использовал 5-слойную вложенность ...
Я отправляю простые объекты между процессами с использованием каналов с многопроцессорным модулем Python.В документации указано, что если канал был закрыт, вызов pipe.recv () должен вызвать ошибку EOFError. ...
По какой-то причине я не могу получить доступ к исключению Queue.Empty - что я здесь делаешь что-то не так? из multiprocessing import Process, Queue # ... try: action = action_queue.get (False) print "Action:" ...
Этот вопрос больше связан с поиском фактов и размышлением, чем с ориентированным на код. У меня есть много скомпилированных программ на C ++, которые мне нужно запустить в разное время и с разными параметрами. Я смотрю на использование ...
Я написал тестовую программу, в которой есть два процесса. Отцовский процесс получает данные из очереди, а дочерний процесс помещает в нее данные. Есть обработчик сигнала, который сообщает программе о выходе. Однако это так ...
В настоящее время я изучаю Python (из фона Java), и у меня есть вопрос о том, что я бы хотел использовали потоки для в Java. Моя программа будет использовать рабочих для чтения из некоторого веб-сервиса…
Я хочу запустить из Python какой-нибудь другой код Python, желательно функцию, но в другом процессе. Это обязательно запускать в другом процессе, потому что я хочу запустить некоторые тесты параллелизма, ...
Я делаю программу, которая читает несколько файлов и записывает сводку каждого файла в выходной файл. Размер выходного файла довольно велик, поэтому хранить его в памяти - не лучшая идея. Я пытаюсь ...
У меня 3 процесса (равный приоритет) P1
P2
Приоритет P3 (таймер) для получения мьютекса следующий: P1 (1 приоритет), P2 (2 приоритета), P3 (таймер) (3 приоритет) Если предположим, что p3 приходит и получает мьютекс
затем приходит p2 ...
Мен ескі ағынды жаңа код орналастыру үшін қолданамын, сол мәселені шешуге тырысады.
Қауіпсіз тұздық дегеніміз не? бұл? сокет импорты ұясынан
ұяшықтан импорт AF_INET
розеткадан ...
Я пытаюсь получить объект трассировки из мультипроцессинга. Процесс. К сожалению, передача информации об исключении через канал не работает, потому что объекты трассировки не могут быть обработаны: def ...
У меня есть код Python ( в Windows), который использует модуль многопроцессорности для запуска пула рабочих процессов. Каждый рабочий процесс должен выполнить некоторую очистку в конце метода map_async. Есть ли ...
from multiprocessing import Process
# c is a container
p = Process(target = f, args = (c,))
p.start() I assume a deep copy of c is passed to function f because shallow copy would make no sense in the ...
У меня два программы python, и я хочу сообщить о них. Оба они являются системными службами, и ни один из них не разветвляется родительским процессом. Есть ли способ сделать это без использования сокетов? (например, ...
The runtime of this code on my laptop for a 4.2 GB input file is 48 seconds. The input file is tab-delimited, with each value appearing in quotes. Each record ends with a newline, e.g. '"val1"\t"val2"\...
Я пытаюсь написать программу Python 2.6 (OSX) с использованием многопроцессорной обработки, и я хочу заполнить очередь более чем 32767 элементами по умолчанию . из многопроцессорной очереди импорта
Queue (2 ** 15) # raises ...
Я могу создать простой php-сервер websocket с помощью libevent, но я застрял, когда пытаюсь сделать его многопроцессорным. например это однократная обработка php
$ socket = ...
Мне нужно написать прокси-программу на Python, рабочий процесс очень похож на веб-прокси. Программа находится между клиентом и сервером, принимает запросы, отправленные клиентом на сервер, ...