Articles of elaborazione parallela

mpi: blocking vs non-blocking

Ho difficoltà a comprendere il concetto di blocco della comunicazione e della comunicazione non bloccante in MPI. Quali sono le differenze tra i due? quali sono i vantaggi e gli svantaggi? Grazie!

Eseguendo un numero limitato di processi figlio in parallelo in bash?

Ho un grande insieme di file per i quali è necessario eseguire alcune elaborazioni pesanti. Questa elaborazione in thread singolo utilizza alcune centinaia di MiB di RAM (sulla macchina utilizzata per avviare il lavoro) e richiede alcuni minuti per essere eseguita. Il mio caso attuale è di avviare un lavoro hadoop sui dati di input, […]

Le nuove parole chiave C # 5.0 “asincrono” e “attendi” utilizzano più core?

Due nuove parole chiave aggiunte al linguaggio C # 5.0 sono asincrone e attendono , entrambe le quali lavorano mano nella mano per eseguire un metodo C # in modo asincrono senza bloccare il thread chiamante. La mia domanda è: questi metodi sfruttano effettivamente più core ed eseguono in parallelo o il metodo asincrono viene […]

Limita il numero di thread paralleli in C #

Sto scrivendo un programma C # per generare e caricare mezzo milione di file via FTP. Voglio elaborare 4 file in parallelo poiché la macchina ha 4 core e la generazione del file richiede molto più tempo. È ansible convertire il seguente esempio di PowerShell in C #? O c’è qualche framework migliore come Actor […]

Salvataggio di più uscite del ciclo di droghe foreach

Mi piacerebbe sapere se / come sarebbe ansible restituire più uscite come parte del ciclo di foreach dopar . Facciamo un esempio molto semplicistico. Supponiamo che mi piacerebbe fare 2 operazioni come parte del ciclo foreach e vorrei restituire o salvare i risultati di entrambe le operazioni per ogni valore di i . Per restituire […]

Julia: come copiare i dati su un altro processore in Julia

Come trasferisci i dati da un processore a un altro in julia? Dì che ho un array a = [1:10] O qualche altra struttura dati. Qual è il modo corretto di metterlo su tutti gli altri processori disponibili in modo che sia disponibile su quei processori come lo stesso nome di variabile?

Il parallelo GNU non funziona affatto

Ho provato a utilizzare GNU parallelamente per un po ‘di tempo, ma non sono mai riuscito a farlo funzionare affatto! Ad esempio, in esecuzione (in una directory non vuota!): ls | parallel echo # Outputs single new line ls | parallel echo echo echo # Outputs three new lines. ls | parallel echo {} # […]

“Parallel.Per” per Java?

Mi chiedevo se esiste un Parallel.Per equivalente alla versione .net per Java? Se c’è qualcuno può fornire un esempio? Grazie!

Si tratta di un bug in Files.lines () o sto fraintendendo qualcosa sugli stream paralleli?

Ambiente: Ubuntu x86_64 (14.10), Oracle JDK 1.8u25 Cerco di utilizzare un stream parallelo di Files.lines() ma voglio .skip() la prima riga (è un file CSV con un’intestazione). Quindi provo a fare questo: try ( final Stream stream = Files.lines(thePath, StandardCharsets.UTF_8) .skip(1L).parallel(); ) { // etc } Ma poi una colonna non è riuscita a analizzare […]

Flussi paralleli, collettori e sicurezza del filo

Vedere il semplice esempio qui sotto che conta il numero di occorrenze di ogni parola in una lista: Stream words = Stream.of(“a”, “b”, “a”, “c”); Map wordsCount = words.collect(toMap(s -> s, s -> 1, (i, j) -> i + j)); Alla fine, wordsCount è {a=2, b=1, c=1} . Ma il mio stream è molto grande […]