BufferedReader - ストリームの終わりでブロックする

Question

私はclojure.asyncを使用してソケットへの読み書きを抽象化するためのいくつかの関数を書いています。私の意図は、値をチャンネルに書き込んで書き込んだり、チャンネルからポップして読み込んだりすることです。このようにして、ユーザーはReader s/Writer秒を心配する必要はありません。

以下のコードはループ内のソケットから読み取ったものを、チャネルに読み込んだものを転送します。チャネルは読み込み可能に返されます。私の問題は、ストリームの終わりに達すると、ブロックするのではなく、何かを読むことができるまでスピンしているということです。これらのプロセスのいくつかを行っている場合、私のコンピュータで顕著なパフォーマンスの問題が発生します。

これを修正するための最も簡単な方法は、nilを返すのではなく、BufferedReaderのreadLineブロックがEOFにあることです。私が見ることができるから、これは不可能です。しかし、ほとんどのストリームでEOFをブロックすることは非常に奇妙なので、私は驚いていません。しかし、ソケットストリームについては、EOFに達してもメッセージを受信できるので、EOFは特定の意味を持たないようです。

EOFに達したら入力を待っている間にループが回転しないようにする方法はありますか？

Answer 1

ここで唯一のことはあなたです。使用しているクラスのメソッドはどれもスピンしません。 isConnectedとisClosedまたはisInputShutdownのドキュメントを読んで、解決策が明確になるはずです。 readLineの説明を読むのにも役立つでしょう。これは、読む入力がなくなったときに何が返ってくるかを非常に明確に示しています。

Answer 2

EOF以降であっても、読み取るべき部分があるかどうかを確認することができます（java.io.BufferedReader.ready()）。また、Socketsは、単に(clojure.java.io/reader socket)を使用してBufferedReaderに強制することができます。ライターと同じです。

私はcore.asyncとはあまりよく慣れていないので、それが役立つかどうかわかりません。