Java使用线程池递归压缩文件夹下面的所有子文件

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

Gzip单个文件压缩

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

1. package date0805.demo1; 
2.  
3. import java.io.BufferedInputStream; 
4. import java.io.BufferedOutputStream; 
5. import java.io.File; 
6. import java.io.FileInputStream; 
7. import java.io.FileOutputStream; 
8. import java.io.InputStream; 
9. import java.io.OutputStream; 
10. import java.util.zip.GZIPOutputStream; 
11.  
12. public class GZipRunnable implements Runnable { 
13.  
14. private final File file; 
15.  
16. public GZipRunnable(File file) { 
17.   this.file=file; 
18. } 
19.  
20. @Override 
21. public void run() { 
22.   if(!file.getName().endsWith(".gz")) { 
23.    File outputFile=new File(file.getParent(),file.getName()+".gz"); 
24.    if(!outputFile.exists()) { 
25.     CountTime countTime = new CountTime(file); 
26.     Thread t=new Thread(countTime); 
27.     t.start(); 
28.     try( 
29.      InputStream in =new BufferedInputStream(new FileInputStream(file)); 
30.      OutputStream out=new BufferedOutputStream(new GZIPOutputStream(new FileOutputStream(outputFile))); 
31.     ) { 
32.      int b; 
33.      while((b=in.read())!=-1) 
34.       out.write(b); 
35.      out.flush(); 
36.     } catch(Exception ex) { 
37.      ex.printStackTrace(); 
38.     } 
39.     t.interrupt(); 
40.    } else { 
41.     System.out.println(outputFile+"文件已经存在，无法压缩!"); 
42.    } 
43.   } 
44. } 
45. } 

创建线程池进行递归压缩

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

1. package date0805.demo1; 
2.  
3. import java.io.File; 
4. import java.util.concurrent.ExecutorService; 
5. import java.util.concurrent.Executors; 
6.  
7. public class GZipFiles { 
8.  
9. private final static int THREAD_COUNT=4; 
10. private static ExecutorService service=Executors.newFixedThreadPool(THREAD_COUNT); 
11. public static void GZip(File fileArgs) { 
12.   if(!fileArgs.isDirectory()) { 
13.    GZipRunnable gZipRunnable = new GZipRunnable(fileArgs); 
14.    service.submit(gZipRunnable); 
15.   } 
16.   else { 
17.    File[] files = fileArgs.listFiles(); 
18.    for(File f:files) { 
19.     GZip(f); 
20.    } 
21.   } 
22. } 
23. public static void shutdown() { 
24.   service.shutdown(); 
25. } 
26. } 

压缩提示

1. package date0805.demo1; 
2.  
3. import java.io.File; 
4.  
5. public class CountTime implements Runnable { 
6.  
7. private File file; 
8.  
9. public CountTime(File file) { 
10.   super(); 
11.   this.file = file; 
12. } 
13.  
14. @Override 
15. public void run() { 
16.   System.out.println("正在压缩"+file.getAbsolutePath()); 
17.   try { 
18.    while(true) { 
19.     System.out.print("."); 
20.     Thread.sleep(1000); 
21.    } 
22.   }catch (InterruptedException e) { 
23.    System.out.println(); 
24.    System.out.println(file.getAbsolutePath()+".gz已经压缩完成！"); 
25.   } 
26. } 
27.  
28. } 

测试代码

1. package date0805.demo1; 
2.  
3. import java.io.File; 
4.  
5. public class Test { 
6.  
7. public static void main(String[] args) { 
8.   File file=new File("D://新建文件夹"); 
9.   GZipFiles.GZip(file); 
10.   GZipFiles.shutdown(); 
11. } 
12. }
    

来源：51CTO