用于即时读取/拉取的自定义缓冲输入流

Question

我需要将 InputStream 传递给一个对象，该对象读取我之前存储到文件中的数据。我正在评估一种比将所有内容存储到文件中然后传递 FileInputStream 更有效的方法。我想即时进行。

有人可以指定我这样做的正确方法吗？

这个想法是传递一个自定义 InputStream，它在内部调用我要存储在文件中的每一行。我想我需要缓冲。我放弃将所有内容存储在 String 中，然后在其上构建 InputStream，因为我们处于相同的情况，等待输出所有行，然后再次重新读取它们。

Answer 1

已经有一个流。这是PipedInputStream。您需要让一个线程写入PipedOutputStream，并将PipedInputStream 传递给将在另一个线程中读取的对象。