スレッドセーフなByteArrayOutputStreamとは何ですか？

Question

私は、プロセスの出力とエラーストリームから読み込み、それらを1つのテキストストリームにマージしたいと思っています。私のプログラムは、グルーヴィーであり、このように読み取ります

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

問題はByteArrayOutputStreamが安全とwaitForProcessOutputスレッドされていないということです（）mergeStreamに追加二つのスレッドを生成します。私が使用できるスレッドセーフなバリアントはありますか？どうすればmergeStreamへのアクセスを制御することをお勧めしますか？実際には、この実装では文字が破棄されることがあります。

Answer 1

process.waitForProcessOutput()が引数としてOutputStreamを取る場合、あなたは単にそのすべてのメソッドが同期しているOutputStreamのカスタム実装を使用して、ラップByteArrayOutputStreamの対応するメソッドに委譲できます。 Collections.synchronizedList()のように、別のリストを同期リストプロキシにラップします。

EDIT：

ByteArrayOutputStreamのソースを読んで、言った、そのすべての方法が既に同期、それはすでにスレッドセーフですされています。あなたのバグはおそらく他の場所から来ています。