import java.io.*;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;/*** 使用多线程拷贝文件夹* 不考虑目的地文件的唯一性。 不按源文件格式拷贝* 每个文件开一条线程去拷贝。最大不超过线程池数量，如果所有线程被占满* 就等待空闲出来的线程，再提交任务** @author silence*/
public class Silence2 {/*** 读取路径*/private static final File INFILE = new File("D:\\Tlias\\新建文件夹\\A210300635\\videosbaselesson");/*** 存储路径*/private static final File OUTFILE = new File("C:\\Users\\Administrator\\Desktop\\新建22)");/*** 线程池*/private static final ThreadPoolExecutor thread;/*** 多线程，线程数*/private static final int SIZE = 100;static {thread = new ThreadPoolExecutor(//核心线程SIZE,//最大线程SIZE,//等待时间2,//等待时间单位TimeUnit.SECONDS,//任务队列，int的最大值，超过的任务，都放到等待队列。new ArrayBlockingQueue<>(10),//线程工厂Executors.defaultThreadFactory(),//拒绝策略new ThreadPoolExecutor.AbortPolicy());}public static void main(String[] args) throws Exception {//判断文件路径ifFile(INFILE);//拷贝文件copyFile(INFILE);//关闭线程池thread.shutdown();}/*** 判断源文件路径* @param file 源文件路径*/private static void ifFile(File file) {//如果路径错误退出if (!file.exists()) {System.out.println("文件路径错误");System.exit(1);}//必须要一个文件夹路径if (!file.isDirectory()) {System.out.println("请传入文件夹路径");System.exit(1);}//文件夹里必须要有文件File[] files = file.listFiles();if (files.length == 0) {System.out.println("不能为空文件夹");System.exit(1);}}/*** 拷贝文件** @param file 文件路径*/private static void copyFile(File file) {File[] files = file.listFiles();for (File f : files) {if (f.isFile()) {while (true) {if (ifThread()) {//如果没有提交满就提交任务thread.submit(() -> {copyF(f);});break;}}} else {//递归copyFile(f);}}}/*** @return true 代表线程池可以接受任务，可以提交*/private static boolean ifThread() {//正在执行的线程数量int activeCount = thread.getActiveCount();//返回允许的最大线程数。int maximumPoolSize = thread.getMaximumPoolSize();//正在执行的线程数量 < 最大线程数  +  等待队列数量6return activeCount < maximumPoolSize;}/*** 拷贝文件** @param f 文件路径*/private static void copyF(File f) {try {System.out.println(getThreadName() + "  正在读取:" + f.getName() + "  文件大小: " + f.length() + " 字节");BufferedInputStream input = new BufferedInputStream(new FileInputStream(f));BufferedOutputStream out = new BufferedOutputStream(new FileOutputStream(new File(OUTFILE, f.getName())));byte[] arr = new byte[1024];int len;while ((len = input.read(arr)) != -1) {out.write(arr, 0, len);}input.close();out.close();System.out.println(getThreadName() + "  完成读取:" + f.getName());} catch (Exception e) {System.out.println(getThreadName() + f.getName() + "文件读取过程中发生错误");e.printStackTrace();System.exit(1);}}/*** 分割线程名*/private static String getThreadName() {String name = Thread.currentThread().getName();return "线程: " + name.substring(name.lastIndexOf("-") + 1);}
}