multiprocessing

5calore

1risposta

worker vs process vs client e job vs task explaination in Celery Python Module

Ho iniziato di recente a lavorare sul calcolo distribuito per aumentare la velocità di calcolo. Dopo una rigorosa ricerca su google e molti forum SO, ho scelto il sedano per il mio scopo, ma sto affro

5calore

1risposta

Perché la multiprocessing di Python è in esecuzione in sequenza?

Di seguito ho trovato un codice molto semplice. #!/Usr/bin/python da multiprocessing importazione Pool tempo import def worker(job): if job in range(25,30): time.sleep(10) print "job:%

9calore

1risposta

Multiprocesso nell'app mobile che fa girare 2 processi

Sto costruendo un'app per flac e ho bisogno di alcuni processi in background da eseguire. Ho deciso di andare con multiprocesso, ma sta producendo due processi durante l'esecuzione all'interno di Flas

5calore

1risposta

gensim LdaMulticore non multiprocessing?

Quando eseguo modello LdaMulticore di gensim su una macchina con 12 core, utilizzando: lda = LdaMulticore(corpus, num_topics=64, workers=10) ottengo un messaggio di registrazione che dice using seri

13calore

2risposta

Attendi che tutti i processi di multiprocesso finiscano prima di continuare

Voglio eseguire una serie di lavori in parallelo e quindi continuare una volta che tutti i lavori sono terminati. Ho qualcosa di simile # based on example code from https://pymotw.com/2/multiprocessin

6calore

1risposta

Come eseguire una funzione più volte in modo asincrono e ottenere il primo risultato

Ho una funzione get_data(request) che richiede alcuni dati a un server. Ogni volta che viene chiamata questa funzione, richiede i dati a un server diverso. Tutti dovrebbero restituire la stessa rispos

5calore

1risposta

Problema di sottoclasse della coda di multiprocessing

Voglio sottoclasse multiprocessing.Queue per l'implementazione dei processi per l'acquisizione di blocchi della coda. L'unico problema è che sto ottenendo uno strano errore TypeError? #!/usr/bin/env p

5calore

1risposta

Elaborazione multiprocesso su pda dataframe

Quindi, quello che sto cercando di fare con il seguente codice è leggere un elenco di liste e metterle attraverso la funzione e poi avere il rapporto log_result con il risultato della funzione checker

5calore

2risposta

Parallelismo aperto a Mp aperto

Quindi ho una regione parallela esterna con due regioni parallele interne. È possibile inserire 2 fili in parallelo esterno e 4 fili in ciascun interno? Ho fatto qualcosa di simile, ma sembra non funz

5calore

1risposta

Python - perché time.sleep causa perdita di memoria?

Quando ho eseguito il codice di seguito, la memoria era in aumento. Tuttavia se ho cancellato time.sleep(3), era 0.1 in top e mai aumentato. Sembra che process non venga terminato correttamente, ma pe