【监听文件 多线程】使用java--WatchService监听文件 开启多线程copy文件

有一个小需求：

在PC跟前没有人的时候，迅雷下载文件 至PC磁盘上，并且自动移动文件到U盘上，小主只要在走的时候取走U盘即可。

基于这个需求，有了下面这段代码：【JDK  1.8】

package com.sxd.moveFile;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.nio.file.StandardWatchEventKinds;
import java.nio.file.WatchKey;
import java.nio.file.WatchService;
import java.util.concurrent.TimeUnit;

import org.junit.Test;

import com.google.common.io.Files;

/**
 * 监听某个文件夹下--如果有新的文件出现 则移动文件到指定目录下
 * @author Administrator
 *
 */
public class MoveFile implements Runnable{
    
    public static String fileName = null;
    
    @Test
    public void test() throws IOException, InterruptedException{
        moveFile();
    }
    
    public void moveFile() throws IOException, InterruptedException{
        
        
            final Path path = Paths.get("E:/迅雷下载");
            final WatchService watchService = path.getFileSystem().newWatchService();
            path.register(watchService, StandardWatchEventKinds.ENTRY_CREATE);//创建并启动监听 --创建文件的事件
            
//            final WatchKey watchKey = watchService.poll(20, TimeUnit.MINUTES);//poll()监听停止的条件--持续20分钟 20分钟后关闭监听
            final WatchKey  watchKey = watchService.take();//take()等不到此类事件发生就一直运行
            
            if(watchKey != null) {
                watchKey.pollEvents().stream().forEach(event ->
                {
                    //执行本次 触发后的方法体
                    System.out.println(event.context());System.out.println(event.kind().name());
                    //仅 判断 新创建文件后缀为.rmvb的   才进行如下 操作
                    if(event.context().toString().substring(event.context().toString().lastIndexOf(".")).equals(".rmvb")  || event.context().toString().substring(event.context().toString().lastIndexOf(".")).equals(".mkv")){
                        fileName = event.context().toString();
                        
                        MoveFile mf = new MoveFile();
                        Thread thread1 = new Thread(mf);//开启一个新的线程 
                        thread1.start();
                    }
                });
                //再次执行
                try {
                    moveFile();
                } catch (Exception e1) {
                    e1.printStackTrace();
                }
                
            }
    
    }

    @Override
    public void run() {
        try {
            Files.copy(new File("E:/迅雷下载/"+fileName), new File("J:/U盘/迅雷下载/"+fileName));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

其中 关于文件系统注册的监听器上，有监听事件类型：

Overflow包含了文件的创建/删除/修改各种事件。