中断BufferedReader＃readLine（）而不关闭InputStream

Question

在InputStream我Process应重视和每当用户希望看到它或不分离。附加工作正常，但分离失败。中断readLine()方法的默认答案始终是关闭流，但是在这种情况下，我将无法Process完成，否则将完成或至少无法用于将来的附件。这是读取流的方式：

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

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

为了分离，我尝试了一些东西：

• 关闭任何流，失败：close方法被阻塞并等待readLine（）
• 实现另一个流，以发送空值/中止值SequenceInputStream，失败：当一个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

我没想到它会起作用，但是期货实际上是可以取消的（但是为什么呢？）。@Tarun
Lalwani提到Google的Guava库的TimeLimiter之后，我检查了一下代码，在示例中进行了尝试（可行！）并将其重写一下-
使它不是基于时间的，而是基于方法调用的？

这是我从研究中得到的结果：的包装器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-loop，但这是通过进行的Reflection，它现在不如我们的解决方案那么漂亮，并且由于任何原因均无法正常工作。该应用程序使用许多进程，但用户数量有限-
这就是为什么我们决定每个用户而不是每个进程确定线程数量的原因。

我希望你们将来会发现这个主题，对您有帮助。如果您留下支持，那将很棒，所以我可以找回我的赏金代表。