0

我有一个守护程序，它读取文件的内容，然后将其压缩并将其写入较小的 .tar.gz 文件。

出于某种原因，Java 继续分配内存，即使在我释放（或我认为我已经）所有使用的内存之后。我的代码/推理有什么问题？

FileOutputStream fos    = null;
GZIPOutputStream gzipos = null;
OutputStreamWriter osw  = null;

BufferedWriter bw = null;
while (true) {
    if (f.length() != 0) {
        if (outputfile == null) {
            outputfile = outputfileroot + "_" + outputPart + ".tar.gz";

            fos = new FileOutputStream(outputfile);
            gzipos  = new GZIPOutputStream(fos);
            osw = new OutputStreamWriter(gzipos);
            bw  = new BufferedWriter(osw);
        }
        else if (new File(outputfile).length() > maxLengthOutputFile) {
            bw.flush();
            osw.flush();
            gzipos.flush();
            fos.flush();
            bw.close();
            osw.close();
            gzipos.close();
            fos.close();

            bw  = null;
            osw = null;
            gzipos  = null;
            fos = null;

            System.gc();

            System.out.println("Finished writing " + outputfileroot + "_" + outputPart + ".tar.gz");

            outputfile = outputfileroot + "_" + ++outputPart + ".tar.gz";
            fos     = new FileOutputStream(outputfile);
            gzipos  = new GZIPOutputStream(fos);
            osw     = new OutputStreamWriter(gzipos);
            bw      = new BufferedWriter(osw);
        }

        /**
         * Read the entire file
         */
        BufferedReader br = new BufferedReader(new FileReader(f));
        String line;
        while ((line = br.readLine()) != null) {
            // will send the content to another thread, so I need to read it line by line
            bw.write(line + "\r\n");
        }
        br.close();
        br = null;
        bw.flush();

        /**
         * Empty it
         */
        FileWriter fw = new FileWriter(f);
        fw.write("");
        fw.flush();
        fw.close();
        fw = null;
    }

    Thread.sleep(1000);
}
4

3 回答 3

2

你煮过头了。所有这些 null 设置和gc()调用实际上并没有帮助，而且您的刷新和关闭次数是您真正需要的数倍。此外，您根本不需要使用 Readers 和 Writers。所有这些都可以简化为：

GZIPOutputStream gzipos = null;
while (true)
{
    if (f.length() != 0)
    {
        if (outputfile == null)
        {
            outputfile = outputfileroot + "_" + outputPart + ".tar.gz";
            gzipos = new GZIPOutputStream(new FileOutputStream(outputfile));
        }
        else
        {
            if (new File(outputfile).length() > maxLengthOutputFile)
            {
                gzipos.close();
                System.out.println("Finished writing " + outputfileroot + "_" + outputPart + ".tar.gz");
                outputfile = outputfileroot + "_" + ++outputPart + ".tar.gz";
                gzipos = new GZIPOutputStream(new FileOutputStream(outputfile));
            }
        }

        /**
         * Read the entire file
         */
        InputStream in = new FileInputStream(f);
        byte[] buffer = new byte[8192];
        int count;
        while ((count = in.read(buffer)) > 0)
        {
            gzipos.write(buffer, 0, count);
        }
        in.close();
        gzipos.flush();
        /**
         * Empty it
         */
        f.createNewFile();
    }
    Thread.sleep(1000);
}

我无法理解您的评论“会将内容发送到另一个线程，因此我需要逐行阅读”。这段代码没有线程，也不需要逐行输入。

我也很好奇它如何与生成输入文件的任何东西交互。我认为您应该重命名输入文件，并在您决定复制它后立即创建一个新的空文件，而不是在复制步骤之后。

于 2013-02-19T23:18:19.787 回答
1

对象不会因为不再被引用而从内存中释放出来。JVM 决定何时运行其“垃圾收集”，从而释放内存。但它通常不会运行垃圾收集，除非它需要。有关更多信息，您可以查看有关该主题的此页面。

您可以调用System.gc()以显式调用垃圾收集器（链接中的第 7 点），但它不必运行。

于 2013-02-19T17:26:36.860 回答
0

System.gc()发送垃圾收集请求。运行时决定是执行它还是忽略所述请求。

于 2013-02-19T17:27:08.533 回答