スレッドが他のスレッドから入力操作を読み飛ばすようにする

Question

ソケット接続用に2つのスレッドSocketInとSocketOutを作成しました（どちらもwhile（true）ステートメントで動作しています）。キーボードの入力を待っています。ヌル値を読み込んでいても、スレッドを閉じたり、while（true）を出さないと、次の命令を実行し続けても、それをやり続ける必要があります。いくつかのアドバイス。CSPプログラミングとBlockingQueue S内に

Answer 1

を見てください。あなたは、「コマンド」を受け入れ、あなたのループでのキューを使用することができます。コマンドの一つは、ソケットから入力され、他のコマンドは、キーボードから入力される。

private final BlockingQueue<Command> inputChannel = new SynchronousQueue<>(); 

public void run() { 
    while (true) { 
     Command request = this.inputChannel.take(); 

     if (request instanceof Command.KeyboardInput) { 
      ... 

     } else { 
      ... 
     } 
    } 
} 

Answer 2

キーボードを読むためにもう1つのスレッドを導入することができます。次に、キーボードリーダーからソケットライター（たとえばBlockingQueue）への中断の豊富な機能を備えた「チャンネル」をいくつか追加してください：

class SocketApp { 
    public static void main(String[] args) throws IOException { 
     ExecutorService pool = Executors.newCachedThreadPool(); 

     URL url = new URL("http://..."); 
     HttpURLConnection con = (HttpURLConnection) url.openConnection(); 
     con.setRequestMethod("POST"); 
     con.setDoOutput(true); 

     OutputStream dst = con.getOutputStream(); 
     InputStream src = con.getInputStream(); 

     // channel between keyboard reader and socket writer 
     BlockingQueue<Integer> consoleToSocket = new ArrayBlockingQueue<>(256); 

     // keyboard reader 
     pool.submit(() -> { 
      while (true) { 
       consoleToSocket.put(System.in.read()); 
      } 
     }); 

     // socket writer 
     pool.submit(() -> { 
      while (true) { 
       dst.write(consoleToSocket.take()); 
      } 
     }); 

     // socket reader 
     pool.submit(() -> { 
      while (true) { 
       System.out.println(src.read()); 
      } 
     }); 
    } 
} 

// Now you can use different features of BlockingQueue. 
// 1. 'poll' with timeout 
// socket sender 
pool.submit(() -> { 
    while (true) { 
     Integer take = consoleToSocket.poll(3, TimeUnit.SECONDS); 
     if (take != null) { 
      dst.write(take); 
     } else { 
      // no data from keyboard in 3 seconds 
     } 
    } 
}); 

// 2. Thread interruption 
// socket sender 
pool.submit(() -> { 
    while (true) { 
     try { 
      Integer take = consoleToSocket.take(); 
      dst.write(take); 
     } catch (InterruptedException e) { 
      // somebody interrupt me wait for keyboard 
     } 
    } 
});