BufferedReader - Блок в конце потока

Question

Я пишу некоторые функции, которые используют clojure.async для абстракции от чтения/записи до сокетов. Мое намерение состоит в том, что значения могут быть помещены в канал, чтобы они были написаны, и выталкивались из канала для чтения. Таким образом, пользователю не нужно беспокоиться о Reader s/Writer s.

Приведенный ниже код считывается из сокета в цикле, пересылая все, что он читает в канал. Канал возвращается, чтобы его можно было прочитать. Моя проблема в том, что когда конец потока достигнут, а не блокируется, он сидит там, пока что-то не читается. Если у меня будет несколько таких процессов, это вызовет заметную проблему с производительностью на моем компьютере.

Самый простой способ, которым я мог это исправить, - это как-то сделать BufferedReaderreadLine блок на EOF вместо возврата nil. Из того, что я вижу, это невозможно. Это меня не удивляет, поскольку блокировка EOF для большинства потоков будет очень странной. Однако для потоков сокетов EOF, похоже, не имеет определенного значения, поскольку сообщения могут быть получены даже после достижения EOF.

Есть ли способ предотвратить вращение цикла при ожидании ввода после достижения EOF?

(ns chat.so-example 
    (:require [clojure.core.async :as a :refer [chan go >!]]) 
    (:import [java.net Socket SocketException] 
      [java.io BufferedReader InputStreamReader InputStream])) 

(defn valid-message? [msg] 
    (and (some? msg) 
     (not (empty? msg)))) 

(defn new-input-chan [^Socket sock] 
    (let [^InputStream in (.getInputStream sock) 
     buff-reader  (BufferedReader. (InputStreamReader. in)) 
     in-chan   (chan)] 
    (go 
     (try 
     (while (.isConnected sock) ; This spins when EOF is reached 
      (let [line (.readLine buff-reader)] 
      (when (valid-message? line) 
       (>! in-chan line)))) 
     (catch SocketException se 
      (#_"Handle exception")) 
     (finally 
      (a/close! in-chan)))) 
    in-chan)) 

Answer 1

Единственное, что крутит здесь, это вы. Ни один из методов в классах, которые вы используете, вращается. Прочтите документацию для isConnected и isClosed или isInputShutdown, и решение должно стать ясным. Это также помогло бы вам прочитать описание readLine, в котором очень четко сказано, что он возвращает, когда больше нет ввода для чтения.

Answer 2

Метод java.io.BufferedReader.ready() может проверить, есть ли еще что-то прочитанное, даже после EOF. Кроме того, Sockets можно принудительно ввести в BufferedReader, используя (clojure.java.io/reader socket). То же самое для писателя.

Я не очень хорошо знаком с core.async, поэтому понятия не имею, если это поможет.