CharBufferが「配管」するのがなぜハングアップするのですか？

Question

次の方法がハングするのはなぜですか？

 
public void pipe(Reader in, Writer out) { 
    CharBuffer buf = CharBuffer.allocate(DEFAULT_BUFFER_SIZE); 
    while(in.read(buf) >= 0) { 
     out.append(buf.flip()); 
    } 
} 

Answer 1

自分の質問に答える：あなたはbuf.clear()read間のを呼び出す必要があります。おそらく、バッファがいっぱいであるため、readがハングしている可能性があります。正しいコードは

 
public void pipe(Reader in, Writer out) { 
    CharBuffer buf = CharBuffer.allocate(DEFAULT_BUFFER_SIZE); 
    while(in.read(buf) >= 0) { 
     out.append(buf.flip()); 
     buf.clear(); 
    } 
} 

Answer 2

となります。デッドロックと思われます。 in.read（buf）はCharBufferをロックし、out.append（buf）呼び出しを防ぎます。

これは、CharBufferが（ある種の）ロックを実装で使用していると仮定しています。 APIがクラスCharBufferについて何を言っていますか？

編集：申し訳ありませんが、私の脳には何らかの種類の短絡があります。私は他のものと混同しました。

Answer 3

CharBuffersは、期待通りに読者とライターではうまく動作しません。特に、Writer.append(CharBuffer buf)メソッドはありません。質問スニペットで呼び出されるメソッドはWriter.append(CharSequence seq)で、これはseq.toString()と呼ばれます。 CharBuffer.toString()メソッドはバッファの文字列値を返しますが、バッファは消耗しません。その後のReader.read(CharBuffer buf)の呼び出しでは、すでにフルバッファが取得されているため、0が返され、ループは無期限に継続されます。

これはハングアップのように感じますが、ループを通過するたびに最初の読み取りのバッファ内容をライターに追加しています。だから、あなたは目的地で多くの出力を見始めるか、作家の実装方法に応じて作家の内部バッファが大きくなるでしょう。

CharBufferソリューションがループを通過するたびに少なくとも2つの新しいchar []をビルドするため、char []実装を推奨します。

public void pipe(Reader in, Writer out) throws IOException { 
    char[] buf = new char[DEFAULT_BUFFER_SIZE]; 
    int count = in.read(buf); 
    while(count >= 0) { 
     out.write(buf, 0, count); 
     count = in.read(buf); 
    } 
} 

私は、そうでない場合のByteBuffer /チャンネルまたはバイト[] /のIOStream実装はあなたが配管の文字をしている場合でも、望ましいだろう、あなたは、2つの文字エンコーディング間の変換をサポートする必要がある場合にのみ、これを使用してお勧めします。