原文链接

本文将介绍Java中利用线程池递归的方式压缩文件夹下面的所有子文件，具体方法如下：

Gzip单个文件压缩

对于单个文件使用GZip压缩。

package date0805.demo1;import java.io.BufferedInputStream;import java.io.BufferedOutputStream;import java.io.File;import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.InputStream;import java.io.OutputStream;import java.util.zip.GZIPOutputStream;public class GZipRunnable implements Runnable {	private final File file;	public GZipRunnable(File file) {		this.file=file;
	}	@Override
	public void run() {		if(!file.getName().endsWith(".gz")) {
			File outputFile=new File(file.getParent(),file.getName()+".gz");			if(!outputFile.exists()) {
				CountTime countTime = new CountTime(file);
				Thread t=new Thread(countTime);
				t.start();				try(
					InputStream in =new BufferedInputStream(new FileInputStream(file));
					OutputStream out=new BufferedOutputStream(new GZIPOutputStream(new FileOutputStream(outputFile)));
				) {					int b;					while((b=in.read())!=-1)
						out.write(b);
					out.flush();
				} catch(Exception ex) {
					ex.printStackTrace();
				}
				t.interrupt();
			} else {
				System.out.println(outputFile+"文件已经存在，无法压缩!");
			}
		}
	}
}

创建线程池进行递归压缩

要实现对一个文件夹下面的所有的子文件进行压缩，首先递归找出所有子文件，然后调用压缩线程进行压缩。

package date0805.demo1;import java.io.File;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;public class GZipFiles {	private final static int THREAD_COUNT=4;	private static ExecutorService service=Executors.newFixedThreadPool(THREAD_COUNT);	public static void GZip(File fileArgs) {		if(!fileArgs.isDirectory()) {
			GZipRunnable gZipRunnable = new GZipRunnable(fileArgs);
			service.submit(gZipRunnable);
		}		else {
			File[] files = fileArgs.listFiles();			for(File f:files) {
				GZip(f);
			}
		}
	}	public static void shutdown() {
		service.shutdown();
	}
}

压缩提示

package date0805.demo1;import java.io.File;public class CountTime implements Runnable {	private File file;	public CountTime(File file) {		super();		this.file = file;
	}	@Override
	public void run() {
		System.out.println("正在压缩"+file.getAbsolutePath());		try {			while(true) {
				System.out.print(".");
				Thread.sleep(1000);
			}
		}catch (InterruptedException e) {
			System.out.println();
			System.out.println(file.getAbsolutePath()+".gz已经压缩完成！");
		}
	}

}

测试代码

package date0805.demo1;import java.io.File;public class Test {	public static void main(String[] args) {
		File file=new File("D://新建文件夹");
		GZipFiles.GZip(file);
		GZipFiles.shutdown();
	}
}