java - 读取解压文件后解压和删除时线程安全

Question

我正在编写一个用于读取zip文件的java代码，如果该文件尚未被其他线程解压缩，则该文件将在当前文件夹中解压缩，然后读取该解压缩的文件。读取后解压的文件将被删除。

例如:如果我在位置/user/home 有一个 zip 文件 test.zip，那么它将在/user/home 解压缩。读取解压文件后文件被删除。

对于单个用户来说它工作正常，但我担心的是当多个用户尝试访问同一个 zip 文件(即 test.zip)并尝试同时解压缩它时。我无法在不影响性能的情况下处理这种情况。我知道我可以使用同步来解压缩和删除方法，但这会影响我的应用程序的性能，因为第二个用户必须等到第一个请求完成，即使它试图解压缩其他文件。

任何建议都会非常有帮助。谢谢。

我使用的包含 javac 的 JDK 是 jdk1.6.0_35

Answer 1

听起来您的问题比您所问的问题稍微复杂一些。

如果我错了，请纠正我，但您真正似乎要问的是，如果给定文件的解压缩已经在进行中，如何继续解压缩其他文件。

抱歉，我想回答这个问题，但没有时间充分解释，所以希望这是清楚的。

如果您不介意一次为多个用户多次解压缩同一个文件，则只需解压缩到临时位置即可完成。

如果您不介意占用大量存储空间，则只需提前解压缩所有文件并保持解压状态即可。您甚至可以通过删除之前解压缩且在一定时间内未使用的数据，或者在达到缓存大小阈值后删除旧数据来限制存储。

但是，如果您不想让文件解压缩，并且不想一次多次解压缩同一文件:首先从基础知识开始，例如:

class ZippedFile {
   public void beginAccess ();
   public void finishAccess ();
}

每个用户在想要访问 zip 文件时调用 beginAccess，并在完成后调用 finishAccess。接下来，您必须稍微改进一下以允许同步:

class ZippedFile {
   public static final int BEGIN_ERROR = 0;
   public static final int BEGIN_BUSY = 1;
   public static final int BEGIN_OK = 2;
   private int refcount = 0;
   public void wantAccess ();   // synchronized internally
   public int beginAccess ();   // synchronized internally
   public void finishAccess (); // synchronized internally
}

现在，beginAccess 应该解压缩文件并正常返回 BEGIN_OK。但是，如果对 beginAccess 的另一个调用当前正在为另一个用户解压缩文件，则它应该立即返回 BEGIN_BUSY。

wantAccess 函数应该增加引用计数并且不执行任何其他操作。

如果引用计数为零，finishAccess 应该减少引用计数并删除解压的内容。如果 finishAccess 正在删除文件，而另一个用户调用 beginAccess，则对 beginAccess 的调用也应返回 BEGIN_BUSY。

现在您有了一个系统，可以让您解压缩一个文件，但同时如果正在解压缩当前文件，则可以继续解压缩下一个文件。下文将更加清楚wantAccess的用法。请注意，每个wantAccess 必须与一个finishAccess 精确匹配。

现在您必须让每个用户处理多个文件，跳过繁忙的文件并稍后返回。你可以这样做:

// in User somewhere...
void processFiles (List<ZippedFile> files) {

    LinkedList<ZippedFile> remaining = new LinkedList<ZippedFile>(files);

    // increase reference counts ahead of time so we hold the files
    // during this entire operation even if other users finish with
    // them in the mean time.
    for (ZippedFile file:remaining)
        file.wantAccess();

    while (!remaining.isEmpty()) {
        ZippedFile file = remaining.removeFirst();
        int status = file.beginAccess();
        if (status == ZippedFile.BEGIN_ERROR)
           file.finishAccess(); // decrease ref count 
        else if (status == ZippedFile.BEGIN_BUSY)
           remaining.addLast(file); // move to end of queue 
        else if (status == ZippedFile.BEGIN_OK) {
           processFileData(file); // do the work
           file.finishAccess(); // done with file
        }
    }

}

确保您的wantAccess、beginAccess 和finishAccess 的实现是通过适当的同步来实现的。您可以存储一个内部标志，指示文件是否已完全解压缩，或者解压缩是否正在进行，并使用它来防止同时发生多个解压缩/删除 - 您不需要同步解压缩/删除本身。

可能还有其他更优雅的方式，但希望这会有所帮助。