Resultados da pesquisa a pedido "multiprocessing"
pool @python apply_async e map_async não são bloqueados na fila completa
Eu sou relativamente novo em python. Estou usando o módulo de multiprocessamento para ler linhas de texto no stdin, convertê-las de alguma forma e gravá-las em um banco de dados. Aqui está um trecho do meu código: batch = [] pool = ...
Multiprocessamento nas quebras do Windows
Desenvolvo com Python no Linux e nunca vi esse tipo de problema com o Windows. Estou usando omultiprocessingiblioteca para acelerar os cálculos, o que funciona muito bem para mim no Linu No Windows, no entanto, as coisas não correm tão bem: * ...
como executar vários executáveis usando python?
Eu tenho um executável no linux. Eu tenho um processador de 8 núcleos. Quero executar 8 instâncias diferentes do mesmo executável com argumentos diferente Eu tente os.system("process_name args") Não retorna até que o processo esteja ...
ompartilhando uma variável entre process
Tenho uma função de download que baixa vários arquivos paralelamente. Eu usomultiprocessing.Pool.map_async para fazer download de diferentes partes do mesmo arquivo. Gostaria de mostrar uma barra de status do download. Para isso, preciso saber o ...
segfault usando lapack_lite de numpy com multiprocessamento no osx, não no linux
O seguinte código de teste segfaults para mim no OSX 10.7.3, mas não em outras máquinas: 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 ...
Alinhamento de memória para FFT rápida em Python usando matrizes compartilhadas
Eu escrevo um aplicativo de processamento de imagens que precisa fazer várias coisas e precisa fazê-las o mais em tempo real possível. A aquisição dos dados e seu processamento são executados em processos separados (principalmente por razões de ...
ompartilhar uma fila de resultados entre vários processo
A documentação para omultiprocessing módulo @ mostra como passar uma fila para um processo iniciado commultiprocessing.Process. Mas como posso compartilhar uma fila com processos assíncronos de trabalho iniciados comapply_async? Não preciso de ...
fork: feche todos os soquetes abertos
Estou usandomultiprocessing.Pool.map, que bifurca o processo atual. Meu entendimento é que, por padrão, todos os descritores de arquivoincluding sockets são copiados do processo mestre ao bifurcar. O processo principal em si é um servidor web ...
multiprocessamento e coleta de lixo
No py2.6 +, omultiprocessing módulo @ oferece umPool class, para que se possa fazer: class Volatile(object): def do_stuff(self, ...): pool = multiprocessing.Pool() return pool.imap(...) No entanto, com a implementação padrão do Python na ...