java - 在不关闭 InputStream 的情况下中断 BufferedReader#readLine()

Question

我的 Process 的 InputStream 应该在用户想要或不想看到它时附加和分离。附加工作正常，但分离失败。中断 readLine() 方法的默认答案始终是关闭流，但在这种情况下我不能这样做，否则 Process 将完成或至少无法用于 future 的附件。这是流的读取方式:

BufferedReader reader = new BufferedReader(new InputStreamReader(getProcess().getInputStream()));
String line;

while ((line = reader.readLine()) != null) {
    System.out.println(line);
}

为了分离我尝试了一些东西:

• 关闭任何流，失败:关闭方法正在阻塞并等待 readLine()
• 用 SequenceInputStream 实现另一个流来发送 null/abortion 值，失败:当一个 InputStream 正在等待输入时，另一个甚至没有被调用

• 使用反射解锁任何流中的 read() 方法，失败:不确定原因，但没有成功。 我们应该继续尝试吗？这是源代码:

  try {
  
      Field modifiers = Field.class.getDeclaredField("modifiers");
      modifiers.setAccessible(true);
  
      Field fdecoder = stream.getClass().getDeclaredField("sd");
      fdecoder.setAccessible(true);
      modifiers.setInt(fdecoder, 1);
      StreamDecoder decoder = (StreamDecoder) fdecoder.get(stream);
  
      Field flock = decoder.getClass().getSuperclass().getDeclaredField("lock");
      flock.setAccessible(true);
      modifiers.setInt(flock, 1);
      Object lock = (Object) flock.get(decoder);
  
      synchronized (lock) {
          lock.notifyAll();
      }
  
  } catch (NoSuchFieldException | IllegalAccessException e) {
      Wrapper.handleException(Thread.currentThread(), e);
  }
  

不确定我该如何解决这个问题。你能帮我在不关闭流的情况下中断 readLine() 方法吗，既简单又高效？谢谢。

编辑:“性能”是什么意思？我的应用程序没有多少用户，但是有很多进程。 @EJP 的回答并没有错——但在我的应用程序中表现不佳。我不能为数百个进程拥有数百个线程，但我可以拥有与用户观看一样多的进程。这就是我尝试优雅地中断该过程的原因。更少的线程，更少的运行/阻塞线程。这是描述的应用程序 ( https://imgur.com/VUcYUfi.png )向用户发送信息的线程与读取输入的线程相同。

Answer 1

我没想到它会起作用，但 future 实际上是可以取消的(但为什么呢？)。在@Tarun Lalwani 提到 TimeLimiter 之后在 Google 的 Guava 库中，我检查了代码，在我的示例中尝试了它(成功了!)并稍微重写了它 - 让它不是基于时间的，而是基于方法调用的？!

这是我从研究中得到的:BufferedReader 的包装器:

public class CancelableReader extends BufferedReader {

    private final ExecutorService executor;
    private Future future;

    public CancelableReader(Reader in) {
        super(in);
        executor = Executors.newSingleThreadExecutor();
    }

    @Override
    public String readLine() {

        future = executor.submit(super::readLine);

        try {
            return (String) future.get();
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        } catch (CancellationException e) {
            return null;
        }

        return null;

    }

    public void cancelRead() {
        future.cancel(true);
    }

}

这class允许您使用 BufferedReader#readLine()当你需要它并在你想继续/中断时取消它 Thread它正在运行。这是它的一些示例代码:

public static void main(String[] args) {

    System.out.println("START");

    CancelableReader reader = new CancelableReader(new InputStreamReader(System.in));
    String line;

    new Thread(() -> {

        try {

            Thread.sleep(10000);
            reader.cancelRead();

        } catch (InterruptedException e) {
            e.printStackTrace();
        }

    }).start();

    while ((line = reader.readLine()) != null) {
        System.out.println(line);
    }

    System.out.println("END");

}

它的输出:

START
> Hello World!
Hello World!
> What's up?
What's up?
END //Exactly after 5 seconds, when the cancel was called
> Hey, you still there?
//No output as expected

我想说的最后一件事是为什么不关闭 InputStream 或为每个进程创建一个线程？在这种情况下 InputStream是 Process 的流，这意味着我们无法关闭它。一种方法是解锁 readLine()并返回 null 以完成 while -循环，但这是用 Reflection 制作的，这不像我们现在的解决方案那么漂亮，而且由于任何原因都不起作用。该应用程序使用许多进程但用户数量有限 - 这就是我们决定每个用户而不是每个进程的线程数量的原因。

我希望你们以后能找到这个线程，它对你有帮助。如果您留下赞成票，那就太棒了，这样我就可以取回我的赏金代表。也不要忘记给评论点赞!他们帮了我很多，让我找到了正确的解决方案: Interrupt BufferedReader#readLine() without closing InputStream