如何异步读取stdin？

Question

当 System.in 中的字符可用时，是否有一种优雅的方式来触发事件？我想避免轮询 InputStream.available()。

Answer 1

您必须创建一个单独的线程来阻止读取，直到有可用的内容为止。

如果您不想真正耗尽输入，则必须用内部缓冲区将其包装起来，读入缓冲区，然后在要求输入时从缓冲区返回数据。

你可以这样解决：

InputStream stdin = System.in;

// Create a wrapper (with it's own dedicated read-thread)
MyListenableInputStream listenableInputStream =
        new MyListenableInputStream(stdin);

// Update System.in with something more useful.
System.setIn(listenableInputStream);

Answer 2

当然...启动一个阻塞输入的线程，然后在获取某些内容时调用您的事件方法。

Answer 3

一般来说：

如果您已经运行了一个事件反应器，请创建一个线程并让它在 read() 上阻塞。当有可用数据时，让该线程将事件排入队列以供反应器处理。如果您无法执行此操作，大多数事件反应器都会提供 InvokeLater 或 CallLater 方法，供您在事件处理线程中运行一些代码。

通知或安排函数调用后，返回到 read() 上阻塞。

Answer 4

如果您想要一些优雅的东西，您可以轻松实现一个 ObservableInputStream ，它接受一个监听器，该监听器会收到有关数据可用性的警告，但您必须使用定期检查的内部线程来实现它获取数据并调用侦听器以防万一。

考虑一下这样一个事实：流不应该用作发送小数据包的对象，而是发送连续的字节流，这就是为什么这种方法只有在提供给输入流的数据实际上没有频繁到达的情况下才有效（否则它会继续随意调用监听器）。此外，您还必须关心一致性，如果数据在某些内容已经可用并且侦听器被警告时到达，那么某些内容可能会占用所有字节（您应该将其放置在临时缓冲区中），但是如果有更多数据刚刚到达，您应该决定如何处理（将其与缓冲区一起提供，放入缓冲区并再次调用侦听器等）

Answer 5

new Thread(){

   public void run() {
      while(System.in.get()){
   }

}.start();