我如何用java首选的java8用多线程解压巨大的文件夹？

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.zip.ZipEntry;
import java.util.zip.ZipInputStream;

public class FileUnzipper {
    public static void main(String[] args) {
        String folderPath = "path/to/folder"; // 要解压的文件夹路径
        int numThreads = 4; // 线程池中的线程数量

        ExecutorService executor = Executors.newFixedThreadPool(numThreads);

        File folder = new File(folderPath);
        File[] files = folder.listFiles();

        for (File file : files) {
            if (file.isFile() && file.getName().endsWith(".zip")) {
                Runnable task = () -> {
                    try (ZipInputStream zipInputStream = new ZipInputStream(new FileInputStream(file))) {
                        ZipEntry entry = zipInputStream.getNextEntry();
                        while (entry != null) {
                            String entryName = entry.getName();
                            File entryFile = new File(folder, entryName);
                            if (entry.isDirectory()) {
                                entryFile.mkdirs();
                            } else {
                                byte[] buffer = new byte[1024];
                                try (FileOutputStream fos = new FileOutputStream(entryFile)) {
                                    int length;
                                    while ((length = zipInputStream.read(buffer)) > 0) {
                                        fos.write(buffer, 0, length);
                                    }
                                }
                            }
                            zipInputStream.closeEntry();
                            entry = zipInputStream.getNextEntry();
                        }
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                };
                executor.submit(task);
            }
        }

        executor.shutdown();
    }
}