2

我第一次尝试使用 java 期货。我设置了一个类来解压缩一些文件。想要递归解压缩，因为我有包含 zip 文件的 zip 文件。

我有一个驱动器类，它实例化一个实现可调用的 Uncompressor 类。Uncompressor 开始解压缩，如果遇到另一个 .zip，它会创建自己的一个实例，将其添加到池中，然后继续。

伪代码

From DriverClass:

.
.
.
ExecutorService pool = new Executors.newFixedThreadPool(4);
Uncompressor uc = new Uncompressor(pool, compressedFile);
Collection<File> files = uc.uncompress();
for(Future <Collection<File>> f : uc.futures)
    files.addAll(f.get());
// at the end of this loop, files doesnt seem to hold all of my files

这是我的解压器类

public class Uncompressor implements Callable<Collection<File>>
{
    public Set<Future<Collection<File>>> futures = new HashSet<Future<Collection<File>>>();
    File compressedFile;
public Uncompressor(ExecutorService pool, File compressedFile)
{
    this.pool = pool;
    this.compressedFile = compressedFile;
}

public Collection<File> call() throws Exception[
   return uncompress();
}

public Collection<File> uncompress()
{
List<File> uncompressedFiles = new ArrayList<File>();
.
.Loop
.//Try to uncompress the file. If the archive entry is a zip file, do the following:

    Callable<Collection<File>> callable = new Uncompressor(this.pool, archiveFileEntry);
    Future f = pool.submit(callable);
    futures.add(f);

 //else, add files to a collection here for returning
 uncompressedFiles.add(archiveFileEntry);

.EndLoop

return uncompressedFiles;
.
.
}

所以问题出在我的 DriverClass 中，我的文件集合应该包含来自递归潜水的所有未压缩文件，这里似乎没有包含所有文件。我认为我在从 Future 获取返回值方面做错了。是因为我futures定义了类成员变量的方式吗？

谢谢

4

1 回答 1

3

如果嵌套深度大于 1，您的代码将无法工作，即顶层 zip 包含一个包含 zip 的 zip。在这种情况下，您的顶级 Uncompressor 不会有底层 zip 文件的未来。

为此使用ForkJoinPool会很酷，因为它更适合递归类型的任务分解。虽然 Java 7 不是一个选项，但我要做的是更改 Uncompressor，以便结果是期货和文件的元组，然后更改调用者以跟踪所有未完成的期货：

--Caller--

Collection<File> alluncompressedFiles = new HashSet<File>();
Collection<Future<UncompressorResult>> futures = new LinkedList<Future<UncompressorResult>>();
Future<UncompressorResult> future = pool.submit(new Uncompressor(pool, compressedFile));
futures.add(future);

while (!futures.isEmpty()) {
    Future<UncompressorResult> future = futures.poll();
    UncompressorResult result = future.get();

    futures.addAll(result.getFutures());
    uncompressedFiles.addAll(result.getFiles());
}

并且解压缩器更改为：

public UncompressorResult call() throws Exception[
    List<File> uncompressedFiles = new ArrayList<File>();

    for (File entry : zipFiles) {
        if (entry is not ZIP) {
            uncompressedFiles.add(entry);
        } else {
            Callable<UncompressorResult> callable = new Uncompressor(this.pool, entry);
            Future<UncompressorResult> f = pool.submit(callable);
            futures.add(f);
        }
    }

    return new UncompressorResult(uncompressedFiles, futures;
}
于 2012-04-20T14:56:32.243 回答