Resultados da pesquisa a pedido "multiprocessing"
Python multiprocessing PicklingError: Não é possível pickle <type 'function'>
Lamento não poder reproduzir o erro com um exemplo mais simples, e meu código é muito complicado para postar. Se eu executar o programa no shell IPython em vez do Python comum, as coisas funcionam be Procurei algumas notas anteriores sobre ...
Forking processos para todas as tarefas no aipo
Atualmente, uso uma biblioteca de extensão C para Python, mas parece haver vazamento de memória. Tarefas executadas no meuceleryd faça algo usando esta biblioteca de extensão C eceleryd consome muita memória cerca de uma hora depois. Não consigo ...
python Pool com Processos de trabalho
Estou tentando usar um pool de trabalhadores em python usando objetos de processo. Cada trabalhador (um Processo) faz alguma inicialização (leva um tempo não trivial), recebe uma série de trabalhos (idealmente usandomap()) e retorna algo. ...
ecuperando informações de forma assíncrona de um proces
Aqui está o pseudo código para o que eu quero fazer. import time def run(): while x < 10000000: x += 1 if __name__ == "__main__": p = Process(run) p.start() time.sleep(3) #some code that I don't know that will give me the current value of ...
sando o multiprocessamento python com semente aleatória diferente para cada proces
Desejo executar várias instâncias de uma simulação em paralelo, mas com cada simulação tendo seu próprio conjunto de dados independent Atualmente, eu implemento isso da seguinte maneira: P = mp.Pool(ncpus) # Generate pool of workers for j in ...
É necessária uma barreira de memória se um segundo thread aguardar o término do primeir
Suponha que o tópicoAlpha está gravando na variávelA sem travar. Uma segunda discussãoBeta está esperando porAlpha para terminar e depois lê a variávelA por sua vez É possível que o conteúdo deA não será fresco? As gravações na memória ...
O multiprocessamento Python nunca se junta a
Estou a usarmultiprocessing, e especificamente umPool para ativar um par de 'threads' para fazer um monte de trabalhos lentos que eu tenho. No entanto, por alguma razão, não consigo reunir o tópico principal, mesmo que todas as crianças pareçam ...
sando o defaultdict com multiprocessament
Apenas experimentando e aprendendo, e sei como criar um dicionário compartilhado que pode ser acessado com vários processos, mas não sei como manter o ditado sincronizado.defaultdict, Acredito, ilustra o problema que estou tend from collections ...
Uso multithread do Stanford Parser
Stanford Parser agora é 'thread-safe' a partir deversion 2.0 [http://nlp.stanford.edu/software/lex-parser.shtml#History] (02.03.2012). No momento, estou executando as ferramentas de linha de comando e não consigo descobrir como usar meus ...
Como o multiprocessing.Manager () funciona em python?
Tenho uma preocupação com o multiprocessing.Manager () em python, aqui está o exemplo, import multiprocessing def f(ns): ns.x *=10 ns.y *= 10 if __name__ == '__main__': manager = multiprocessing.Manager() ns = manager.Namespace() ns.x = 1 ns.y ...