Java PipedInputStreamスレッドは、ロックを保持している他のスレッドがないBLOCKED状態ですか？

Question

私はapache httpクライアントを使用して、パイプでストリームを使用してコンテンツを書き込む、いくつかの投稿要求をターゲットサーバに実行しています。ですから、基本的には、あるスレッドのHTTPクライアントはPipedInputStreamから読み込み、別のスレッドからはPipedOutputStreamのコンテンツを書きます。

毎回、スレッドダンプを取得していて、java.io.PipedInputStream.read()メソッドがブロックされているのを確認して、wait(1000)行を実行しています。 BLOCKED状態は、1000 msが経過した後に読み取りスレッドがロックを取得するのを待機していることを意味します。しかし、私が理解していないのは、スレッドダンプでロックを保持する書き込みスレッドを見ることができない理由です。何が欠けていて、スレッドをブロックしないようにするにはどうすればいいですか？

Thread 7912: (state = BLOCKED) 
- java.lang.Object.wait(long) @bci=0 (Compiled frame; information may be imprecise) 
- java.io.PipedInputStream.read() @bci=142, line=326 (Compiled frame) 
- java.io.PipedInputStream.read(byte[], int, int) @bci=43, line=377 (Compiled frame) 
- org.apache.http.entity.InputStreamEntity.writeTo(java.io.OutputStream) @bci=75, line=140 (Compiled frame) 
- org.apache.http.impl.execchain.RequestEntityProxy.writeTo(java.io.OutputStream) @bci=10, line=123 (Compiled frame) 
- org.apache.http.impl.DefaultBHttpClientConnection.sendRequestEntity(org.apache.http.HttpEntityEnclosingRequest) @bci=31, line=156 (Compiled frame) 
- org.apache.http.impl.conn.CPoolProxy.sendRequestEntity(org.apache.http.HttpEntityEnclosingRequest) @bci=5, line=162 (Compiled frame) 
- org.apache.http.protocol.HttpRequestExecutor.doSendRequest(org.apache.http.HttpRequest, org.apache.http.HttpClientConnection, org.apache.http.protocol.HttpContext) @bci=223, line=238 (Compiled frame) 
- org.apache.http.protocol.HttpRequestExecutor.execute(org.apache.http.HttpRequest, org.apache.http.HttpClientConnection, org.apache.http.protocol.HttpContext) @bci=25, line=123 (Compiled frame) 
- org.apache.http.impl.execchain.MainClientExec.execute(org.apache.http.conn.routing.HttpRoute, org.apache.http.client.methods.HttpRequestWrapper, org.apache.http.client.protocol.HttpClientContext,  org.apache.http.client.methods.HttpExecutionAware) @bci=714, line=271 (Compiled frame) 
- org.apache.http.impl.execchain.ProtocolExec.execute(org.apache.http.conn.routing.HttpRoute, org.apache.http.client.methods.HttpRequestWrapper, org.apache.http.client.protocol.HttpClientContext, org.apache.http.client.methods.HttpExecutionAware) @bci=447, line=184 (Compiled frame) 
- org.apache.http.impl.execchain.RetryExec.execute(org.apache.http.conn.routing.HttpRoute, org.apache.http.client.methods.HttpRequestWrapper, org.apache.http.client.protocol.HttpClientContext, org.apache.http.client.methods.HttpExecutionAware) @bci=39, line=88 (Compiled frame) 
- org.apache.http.impl.client.InternalHttpClient.doExecute(org.apache.http.HttpHost, org.apache.http.HttpRequest, org.apache.http.protocol.HttpContext) @bci=168, line=184 (Compiled frame) 
- org.apache.http.impl.client.CloseableHttpClient.execute(org.apache.http.client.methods.HttpUriRequest, org.apache.http.protocol.HttpContext) @bci=14, line=82 (Compiled frame) 
- org.apache.http.impl.client.CloseableHttpClient.execute(org.apache.http.client.methods.HttpUriRequest) @bci=6, line=107 (Compiled frame) 

Answer 1

あなたがたInputStreamで読む呼び出すときのOutputStreamは、最終的にデータを取得するまでは待機します：ここで

は、スレッドダンプファイル内からいくつかの行があります。だからこそ、あなたはブロークを待っています。したがって、それは書き込みとロックではなく、inputStreamにデータがある間は読み込みと待機に関するものです。あなたはPipedInputStreamにread()を呼び出すと、バッファが空になると、対応するPipedOutputStreamが何かとPipedInputStreamが待機しているオブジェクトどんな通知を書き込むまで

Answer 2

、それはいくつかのオブジェクトにwait()にブロックします。これはwait()同期との通知する他の誰かのためにロックを解除するだけでお馴染みの

synchronized (lock) 
{ 
    while (...) 
     lock.wait(); 
} 

パターン、です。

なぜパイプラインを使用しているのかは別の謎です。彼らはおもちゃだけです。