问题标签 [inputstream]

我们如何为黑莓编写循环缓冲区？

我知道该getResourceAsStream()方法，但是读取文件的解析器存在问题，整个结构被实现为期望 aFileInputStream()并且getResourceAsStream()返回一个无法转换的输入流。这种情况有什么简单的“修复”吗？

我正在尝试构建一个应用程序来检测来自网页的广告图像。一旦我检测到这些，我将不允许它们显示在客户端。

基本上，我使用反向传播算法使用此处给出的数据集训练神经网络：http: //archive.ics.uci.edu/ml/datasets/Internet+Advertisements。

但在那个数据集中没有。的属性非常高。事实上，该项目的一位导师告诉我，如果你用这么多属性训练神经网络，那么训练起来需要很多时间。那么有没有办法优化输入数据集呢？或者我只需要使用那么多属性？

我正在使用 java.util.Scanner 来处理诸如 nextInt() 之类的事情，只要我使用 java.lang.Readable（一个也是唯一的构造函数参数），一切都可以正常工作。但是，当我改为使用 InputStream 时， Scanner.nextInt() 永远不会返回。你知道为什么吗？

我的 InputStream 实现如下所示：

当我通过 THE COMMENT 打印数据时，我（正确地）得到诸如“12\n”的“1”、“2”、“\n”之类的东西。是否有一些我不知道的扫描仪连接会导致这种行为?

对于我在 Linux 中实现 tail shell 命令，我需要使用流输入/输出从文件末尾读取一定数量的行/字节。有没有人有建议如何做到这一点？我怀疑我需要打开一个文件并将一些参数传递给 ifstream 构造函数，但我不知道究竟是什么。谷歌搜索没有找到任何东西。

我的数据库表中有一个 blob 列，我必须byte[]在我的 Java 程序中将其用作映射，并且要使用此数据，我必须将其转换为InputStreamor OutputStream。但我不知道当我这样做时内部会发生什么。谁能简要解释一下我进行此转换时发生了什么？

在伪代码中，这就是我正在做的事情：

但是，有时processOutputStreamInThread看不到任何输出，有时会看到。粗略地说，该方法创建BufferedInputStream命令的输出并将其发送到记录器。

根据我所看到的，我猜测command不需要将所有输出转储到由getInputStream()and馈送的流getErrorStream()中，从而允许流为空。

我的试验结果是以下问题：

(1) java.lang.ProcesswaitFor()中是否要求执行程序的输出在返回之前已被读取？

该文档仅说明：

如有必要，使当前线程等待，直到此Process对象表示的进程终止。如果子进程已经终止，则此方法立即返回。如果子进程尚未终止，则调用线程将被阻塞，直到子进程退出。

(2)在什么条件下，由提供的流需要关闭和/或自动关闭getInputStream？getErrorStream

该文档仅说明：

获取子流程的错误流。该流从该 Process 对象表示的进程的错误输出流中获取通过管道传输的数据。

实施说明：缓冲输入流是个好主意。

一位用户报告说他必须自己关闭流，但至少在部分时间我得到一个异常，表明当我尝试这样做时流已经关闭。

编辑：更改getOutputStream为getInputStream，现在出现在上面。

解决方案：问题最终是在某些情况下，用于处理输出流的线程直到我的非常短暂的进程完成后才会运行，导致输入流没有给我任何数据。 waitFor没有做任何等待执行程序的输出。相反，程序在收集任何输出之前运行并终止。

我使用线程是因为我不确定我将在标准错误和标准输出上获得多少输出，并且我希望能够同时处理这两者，而不会阻塞其中一个或另一个应该只有其中一个有可用数据。但是，因为我的线程不能一致地读取执行程序的输出，所以这是一个非解决方案。

我的最终编码看起来像这样：

我编写了包装其他流的后台InputStream（和OutputStream）实现，并在后台线程上预读，主要允许在处理解压缩流的不同线程中进行解压缩/压缩。

这是一个相当标准的生产者/消费者模型。

这似乎是一种通过读取、处理和写入数据的简单进程充分利用多核 CPU 的简单方法，从而更有效地利用 CPU 和磁盘资源。也许“高效”不是最好的词，但与直接从 a 读取ZipInputStream和直接写入a 相比，它提供了更高的利用率，而且我更感兴趣的是，它减少了运行时间ZipOutputStream。

我很高兴发布代码，但我的问题是我是否正在重新发明现有（并且更频繁地使用）库中现成的东西？

编辑 - 发布代码...

我的代码BackgroundInputStream如下（BackgroundOutputStream非常相似），但有些方面我想改进。

1. 看起来我工作太努力了，无法来回传递缓冲区。
2. 如果调用代码丢弃对 的引用BackgroundInputStream，则backgroundReaderThread将永远存在。
3. 信号eof需要改进。
4. 异常应该传播到前台线程。
5. 我想允许使用提供的线程Executor。
6. 该close()方法应该向后台线程发出信号，并且不应该关闭包装的流，因为包装的流应该由从中读取的后台线程拥有。
7. 关门后做一些傻事，比如看书，应该得到适当的照顾。

我正在使用LogManager.readConfiguration()它需要一个 InputStream，我希望它的内容来自一个字符串。是否有StringBufferInputStream不被弃用的等价物，例如ReaderToInputStreamAdaptor?

我的背景是 .net，我对 Java 还很陌生。我正在为我们公司的 java 团队做一些工作，架构师需要我实现一个采用 InputStream (java.io) 对象的方法。为了实现该方法的目的，我需要将其转换为字节数组。是否有捷径可寻？