python-multiprocessing

1зной

1ответ

Python: взаимозависимые очереди процесс/нить

У меня есть четыре очереди, каждый из которых имеет несколько процессов/потоков, которые взаимосвязаны следующим образом: очереди 1 чтение файла с диска и копирования в ОЗУ Очередь 2 принимает файл в

1зной

1ответ

Файла Handle открыт для родительского процесса, но закрыт для каждого дочернего процесса

я написал этот небольшой пример: import multiprocessing from functools import partial def foo(x, fp): print str(x) + " "+ str(fp.closed) return def main(): with open("test.txt", 'r

0зной

1ответ

Python многопроцессорной Инициализация массива

Я пытаюсь использовать Process Массивы для того, чтобы использовать структуру массива между несколькими процессами, но не могу показаться, чтобы инициализировать the example: from multiprocessing impo

0зной

3ответ

многопроцессорная работа с функцией python

Как я могу реализовать многопроцессорную функцию для моей функции. Я так пробовал, но не работал. def steric_clashes_parallel(system): rna_st = system[MolWithResID("G")].molecule() for i in

0зной

1ответ

Совместное использование файловых дескрипторов в многопроцессорной обработке Python

Я пытаюсь использовать модуль многопроцессорности Pythons, чтобы создать сервер для получения сообщений UDP, немного их модифицировать и передать их процессу grep, запущенному с модулем подпроцесса. П

1зной

1ответ

Безопасность совместного использования разреженной разрешающей матрицы только для чтения между несколькими процессами

У меня есть расчет, который я должен сделать, что несколько дорого, и я хочу, чтобы создать несколько процессов для его завершения. Суть в том, что: 1) У меня есть большой scipy.sparse.csc_matrix (при

2зной

2ответ

Могу ли я использовать map/imap/imap_unordered с функциями без аргументов?

Иногда мне нужно использовать многопроцессорность с функциями без аргументов. Я хотел бы сделать что-то вроде: from multiprocessing import Pool def f(): # no argument return 1 # TypeError: f(

4зной

1ответ

Программа работает с map(), но вызывает TypeError с pool.map()

У меня есть программа, которая долгое время не использовалась, но она уже используется и работает. Он использует многопроцессорность, поскольку одна и та же задача должна выполняться для разных данных

1зной

1ответ

Многопроцессорная обработка с функциями подпроцесса

Я пишу программу, которая имеет функции, которые используют подпроцессы для приема/передачи сообщений, однако я хочу иметь возможность запускать прием в фоновом режиме, имея возможность печатать все,