multiprocessing

12calore

1risposta

Debug dei sottoprocessi Popen con PyCharm

Sto provando a eseguire il debug di un'applicazione Python che utilizza oggetti psutil.Popen. Quando inizio un sottoprocesso, PyCharm sostituisce la mia linea di comando con il seguente: python -m pyd

8calore

2risposta

Accesso a un attributo di un proxy multiprocessing di una classe

Ho una classe che desidero condividere in modalità di sola lettura con processi figli in un pool, quindi ho preparato un proxy di una classe ma non ha funzionato. Quello che segue è un esempio semplif

6calore

3risposta

Sedano - Completa compito, ma non restituisce il risultato

Ho appena installato sedano e sto cercando di seguire il tutorial: Ho un file chiamato tasks.py con il seguente codice: from celery import Celery app = Celery('tasks', backend='amqp', broker='amqp:/

5calore

2risposta

Processo di multiprocessing Python numero

Utilizzo il modulo del pool di multiprocessing Python per creare un pool di processi e assegnarvi lavori. ho creato 4 processo e l'assegnazione di 2 posti di lavoro, ma cercando di mostrare il loro nu

7calore

1risposta

Lo script che utilizza il modulo multiprocessing non termina

Il seguente codice, non viene stampato "here". Qual è il problema? L'ho provato su entrambe le mie macchine (Windows 7, Ubuntu 12.10), e http://www.compileonline.com/execute_python_online.php Non stam

12calore

2risposta

si applica il multiprocessing panda

Sto provando a utilizzare la multiprocessing con pandas dataframe, ovvero il dataframe diviso in 8 parti. applica alcune funzioni a ciascuna parte usando apply (con ogni parte elaborata in processi di

6calore

1risposta

Code di multiprocessing in Python più lente di pool.map

Recentemente ho iniziato a sperimentare con il multiprocessing per velocizzare un'attività. Ho creato uno script che combina le stringhe fuzzy e calcola i punteggi utilizzando diversi algoritmi (volev

6calore

2risposta

Come uccidere tutti i pool worker in multiprocesso?

Voglio interrompere tutti i thread da un singolo operatore. Ho un pool di thread con 10 lavoratori: def myfunction(i): print(i) if (i == 20): sys.exit() p = multiprocessing.Pool(10,

23calore

5risposta

Perché questo codice non scala in modo lineare?

Ho scritto questo codice SOR solver. Non preoccupatevi troppo di ciò che fa questo algoritmo, non è la preoccupazione qui. Ma solo per completezza: può risolvere un sistema lineare di equazioni, a sec

14calore

2risposta

Come utilizzare ipdb.set_trace in un processo a forcella

Io uso ipdb.set_trace() ogni volta che ho bisogno di impostare un punto di interruzione nel mio codice. In questo momento, sto cercando di usarlo in un processo che ho creato usando multiprocessing, m