java - GZIPOutputStream 在单独的线程中进行压缩

Question

是否有 GZIPOutputStream 的实现可以在单独的线程中完成繁重的工作(压缩+写入磁盘)？

我们正在不断写入大量 GZIP 压缩数据。我正在寻找一个可以代替 GZIPOutputStream 的直接替代品。

Answer 1

您可以写入 PipedOutputStream 并有一个线程读取 PipedInputStream 并将其复制到您喜欢的任何流。

这是一个通用实现。您给它一个要写入的 OutputStream，它会返回一个要写入的 OutputStream。

public static OutputStream asyncOutputStream(final OutputStream out) throws IOException {
    PipedOutputStream pos = new PipedOutputStream();
    final PipedInputStream pis = new PipedInputStream(pos);
    new Thread(new Runnable() {
        @Override
        public void run() {
            try {
                byte[] bytes = new byte[8192];
                for(int len; (len = pis.read(bytes)) > 0;)
                    out.write(bytes, 0, len);
            } catch(IOException ioe) {
                ioe.printStackTrace();
            } finally {
                close(pis);
                close(out);
            }
        }
    }, "async-output-stream").start();
    return pos;
}

static void close(Closeable closeable) {
    if (closeable != null) try {
        closeable.close();
    } catch (IOException ignored) {
    }
}