ok risolto! la coda era effettivamente inutile... il tutto si semplifica e
di molto, grazie per i link.
il codice funzionante è:
#!python
import multiprocessing as mltp
def work((x, y)):
return x * y
pool = mltp.Pool()
res = pool.map_async(work, zip(range(100), range(100, 200)))
result
map+reduce?
http://mikecvet.wordpress.com/2010/07/02/parallel-mapreduce-in-python/
Il giorno 02 aprile 2013 00:52, Pietro ha scritto:
> Ciao a tutti,
>
> Sto utilizzando una funzione C su una grande matrice, questa operazione
> richiede parecchio tempo e vorrei dividere la matrice in sotto mat
Ciao Enrico,
2013/4/2 Enrico Franchi
>
> On Apr 2, 2013, at 12:52 AM, Pietro wrote:
> > Sto utilizzando una funzione C su una grande matrice, questa operazione
> > richiede parecchio tempo e vorrei dividere la matrice in sotto matrici e
> > lanciare un processo per ogni sotto-matrice…
>
> Io v
On Apr 2, 2013, at 12:52 AM, Pietro wrote:
> Sto utilizzando una funzione C su una grande matrice, questa operazione
> richiede parecchio tempo e vorrei dividere la matrice in sotto matrici e
> lanciare un processo per ogni sotto-matrice…
Io vorrei capire se quella cosa che hai postato e' so