Articles of elaborazione parallela

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 […]

Come posso stampare quando uso% dopar%

Ho un ciclo foreach che utilizza %dopar% con doSNOW come back-end. Come posso far stampare al loop qualcosa fuori ogni iterazione? Il mio codice qui sotto è quello che sto attualmente usando, ma non stampa nulla. foreach(ntree=rep(25,2),.combine=combine,.packages=’randomForest’, .inorder=FALSE) %dopar% { print(“RANDOM FOREST”) randomForest(classForm,data=data,na.action=na.action,do.trace=do.trace,ntree=ntree,mtry=mtry) }

Riduzione su array in OpenMP

Sto cercando di parallelizzare il seguente programma, ma non so come ridurre su un array. So che non è ansible farlo, ma c’è un’alternativa? Grazie. (Ho aggiunto una riduzione su m che è sbagliato ma vorrei avere un consiglio su come farlo). #include #include #include #include using namespace std; int main () { int A […]

Parallel.ForEach limita il numero di thread attivi?

Dato questo codice: var arrayStrings = new string[1000]; Parallel.ForEach(arrayStrings, someString => { DoSomething(someString); }); Tutti i 1000 thread verranno generati quasi contemporaneamente?

Come creare thread in nodejs

C’è un modo per creare thread per l’esecuzione di più metodi alla volta. Se qualsiasi metodo fallisce tra tutti gli altri thread dovrebbe essere ucciso. Grazie in anticipo

Come aspettare che un numero di thread completi?

Qual è un modo per attendere semplicemente che tutto il processo a thread venga completato? Ad esempio, supponiamo di avere: public class DoSomethingInAThread implements Runnable{ public static void main(String[] args) { for (int n=0; n<1000; n++) { Thread t = new Thread(new DoSomethingInAThread()); t.start(); } // wait for all threads' run() methods to complete before […]

È ansible abortire un’attività come abortire una discussione (metodo Thread.Abort)?

Potremmo abortire un thread come questo: Thread thread = new Thread(SomeMethod); . . . thread.Abort(); Ma posso abortire un compito (in .Net 4.0) nello stesso modo non con il meccanismo di cancellazione. Voglio uccidere immediatamente il compito.

Perché il pacchetto parallelo è più lento del semplice utilizzo di apply?

Sto cercando di determinare quando utilizzare il pacchetto parallel per accelerare il tempo necessario per eseguire alcune analisi. Una delle cose che devo fare è creare matrici che confrontino le variabili in due frame di dati con un numero di righe diverso. Ho fatto una domanda su un modo efficiente di fare su StackOverflow e […]

Coordinamento dell’esecuzione parallela in node.js

Il modello di programmazione event-driven di node.js rende piuttosto complicato coordinare il stream del programma. La semplice esecuzione sequenziale viene trasformata in callback annidati, il che è abbastanza semplice (anche se un po ‘complicato da scrivere). Ma per quanto riguarda l’esecuzione parallela? Supponiamo che tu abbia tre compiti A, B, C che possono essere eseguiti […]