本文將介紹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(); 
} 
}