Articles of stream

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

Node.js Piping lo stesso stream leggibile in più target (scrivibili)

Devo eseguire due comandi in serie che devono leggere i dati dallo stesso stream. Dopo aver collegato un stream a un altro, il buffer viene svuotato, quindi non posso leggere di nuovo i dati da quel stream, quindi questo non funziona: var spawn = require(‘child_process’).spawn; var fs = require(‘fs’); var request = require(‘request’); var inputStream […]

Flussi di Java 8: perché lo streaming parallelo è più lento?

Sto giocando con gli stream di Java 8 e non riesco a capire i risultati delle prestazioni che sto ottenendo. Ho 2 core CPU (Intel i73520M), Windows 8 x64 e 64-bit Java 8 update 5. Sto facendo una semplice mappa su stream / stream parallelo di stringhe e ho scoperto che la versione parallela è […]

“Parametro non valido” caricamento di eccezione System.Drawing.Image

Perché sto ricevendo l’eccezione “Parametro non valido” nel mio codice: MemoryStream ms = new MemoryStream(byteArrayIn); System.Drawing.Image returnImage = System.Drawing.Image.FromStream(ms); La lunghezza di byteArrayIn è 169014. Ricevo questa eccezione nonostante il fatto che nessun valore in esso sia maggiore di 255.

Come posso comporre i flussi di output, in modo che l’output vada in più posti contemporaneamente?

Mi piacerebbe comporre due (o più) flussi in uno solo. Il mio objective è che qualsiasi output diretto a cout , cerr e clog venga emesso anche in un file, insieme al stream originale. (Per quando, ad esempio, le cose vengono registrate sulla console. Dopo la chiusura, mi piacerebbe essere ancora in grado di tornare […]

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

Modifica una riga specifica di un file di testo in C #

Ho due file di testo, Source.txt e Target.txt. La sorgente non verrà mai modificata e contiene N righe di testo. Quindi, voglio eliminare una specifica riga di testo in Target.txt e sostituirla con una specifica riga di testo da Source.txt, so quale numero di linea ho bisogno, in realtà è il numero di riga 2, […]

Deserializzare l’array json in streaming un elemento alla volta

Serializzo una serie di oggetti di grandi dimensioni su un stream di risposta http Json. Ora voglio deserializzare questi oggetti dal stream uno alla volta. Ci sono delle librerie c # che mi permetteranno di fare questo? Ho guardato json.net ma sembra che avrei dovuto deserializzare l’intera gamma di oggetti contemporaneamente. [{large json object},{large json […]

Come funziona std :: flush work?

Qualcuno può spiegare (preferibilmente usando un semplice inglese) come std::flush funziona? Che cos’è? Quando svuotare un stream? Perché è importante? Grazie.

Manipolatore di stream personalizzato C ++ che modifica l’elemento successivo nello stream

In C ++, per stampare un numero in esadecimale, fai questo: int num = 10; std::cout << std::hex < ‘a’ So che posso creare un manipolatore che aggiunge solo cose allo stream in questo modo: std::ostream& windows_feed(std::ostream& out) { out << "\r\n"; return out; } std::cout << "Hello" < “Hello\r\n” Tuttavia, come posso creare un […]