Che cos'è un ByteArrayOutputStream sicuro per i thread?

Question

Mi piacerebbe leggere dall'output di un processo e dai flussi di errore e unirli in un unico flusso di testo. Il mio programma è in Groovy e si legge come questo:

def mergeStream = new ByteArrayOutputStream() 
process.waitForProcessOutput(mergeStream, mergeStream) 

Il problema è che ByteArrayOutputStream non è thread-safe e waitForProcessOutput() genera due fili che aggiungere al mergeStream. C'è una variante thread-safe che posso usare? In quale altro modo si consiglia di controllare l'accesso a mergeStream? Sembra che in pratica i personaggi vengano talvolta abbandonati con questa implementazione.

Answer 1

Se il process.waitForProcessOutput() prende un OutputStream come argomento, si può semplicemente utilizzare un'implementazione personalizzata OutputStream che ha tutti i metodi sincronizzati, e delegare il metodo corrispondente di una avvolto ByteArrayOutputStream. Proprio come Collections.synchronizedList() avvolge un altro Elenco in un proxy Elenco sincronizzato.

EDIT:

Detto, leggendo la fonte di ByteArrayOutputStream, tutti i metodi sono già sincronizzati, quindi è già thread-safe. Il tuo bug probabilmente viene da altrove.