用java实现文件查找，我们用多线程与单线程实现，对比一下使用多线程的区别

单线程

假设你的项目目录是 e:/project，遍历这个目录下所有的java文件（包括子文件夹），找出文件内容包括 Magic的那些文件，并打印出来。

{
    /** * @param file 查找的目录 * @param search 查找的字符串 */
    public static void search(File file, String search) {
        if (file.isFile()) {
        	//如果文件以.java结尾
            if(file.getName().toLowerCase().endsWith(".java")){
            	//获得文件字符串
                String fileContent = readFileConent(file);
               	//contains（）,该方法是判断字符串中是否有子字符串。如果有则返回true，如果没有则返回false。
                if(fileContent.contains(search)){
                    System.out.printf("找到子目标字符串%s,在文件:%s%n",search,file);
                }
            }
        }
        if (file.isDirectory()) {
            File[] fs = file.listFiles();
            for (File f : fs) {
                search(f, search);
            }
        }
    }
    //读取文件中的所有字符，返回字符串
    public static String readFileConent(File file){
        try (FileReader fr = new FileReader(file)) {
            char[] all = new char[(int) file.length()];
            fr.read(all);
            return new String(all);
        } catch (IOException e) {
            e.printStackTrace();
            return null;
        }
 
    }

    public static void main(String[] args) {
        File folder =new File("D:\\Workspaces\\IDEA\\leetcode\\src\\project");
        long startTime = System.currentTimeMillis();    //获取开始时间
        search(folder,"Magic");
        long endTime = System.currentTimeMillis();    //获取结束时间
        System.out.println("程序运行时间：" + (endTime - startTime) + "ms");    //输出程序运行时间
    }
}

把单线程改为多线程查找文件内容，单线程的思路是遍历所有文件，当遍历到文件是 .java的时候，查找这个文件的内容，查找完毕之后，再遍历下一个文件

多线程

现在通过多线程调整这个思路：遍历所有文件，当遍历到文件是.java的时候，创建一个线程去查找这个文件的内容，不必等待这个线程结束，继续遍历下一个文件

首先准备一个SerachFileThread,继承Thread类，并重写run方法。 在run方法中，读取文件内容并查找

package multiplethread;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
public class SearchFileThread extends Thread{
    private File file;
    private String search;
    public SearchFileThread(File file,String search) {
        this.file = file;
        this.search= search;
    }  
    public void run(){
        String fileContent = readFileConent(file);
        if(fileContent.contains(search)){
            System.out.printf("找到子目标字符串%s,在文件:%s%n",search,file);
        }
    }
    public String readFileConent(File file){
        try (FileReader fr = new FileReader(file)) {
            char[] all = new char[(int) file.length()];
            fr.read(all);
            return new String(all);
        } catch (IOException e) {
            e.printStackTrace();
            return null;
        }
    }  
}

然后在遍历文件的时候，如果是以.java结尾，则启动一个SerachFileThread线程，进行查找工作

package multiplethread;

import java.io.File;
public class TestThread {
    public static void search(File file, String search) {
        if (file.isFile()) {
            if(file.getName().toLowerCase().endsWith(".java")){
                //当找到.java文件的时候，就启动一个线程，进行专门的查找
                new SearchFileThread(file,search).start();
            }
        }
        if (file.isDirectory()) {
            File[] fs = file.listFiles();
            for (File f : fs) {
                search(f, search);
            }
        }
    }
    public static void main(String[] args) {
        File folder =new File("D:\\Workspaces\\IDEA\\leetcode\\src\\project");
        long startTime = System.currentTimeMillis();    //获取开始时间
        search(folder,"Magic");
        long endTime = System.currentTimeMillis();    //获取结束时间
        System.out.println("程序运行时间：" + (endTime - startTime) + "ms");    //输出程序运行时间
    }
}

java如何计算程序运行时间

第一种。

long startTime = System.currentTimeMillis();    //获取开始时间
doSomething();    //测试的代码段
long endTime = System.currentTimeMillis();    //获取结束时间
System.out.println("程序运行时间：" + (endTime - startTime) + "ms");    //输出程序运行时间

第二种是以纳秒为单位计算的。

long startTime=System.nanoTime();   //获取开始时间 
doSomeThing(); //测试的代码段 
long endTime=System.nanoTime(); //获取结束时间 
System.out.println("程序运行时间： "+(endTime-startTime)+"ns");

线程池

线程池类ThreadPoolExecutor在包java.util.concurrent下

ThreadPoolExecutor threadPool= new ThreadPoolExecutor(10, 15, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());

第一个参数10 表示这个线程池初始化了10个线程在里面工作
第二个参数15 表示如果10个线程不够用了，就会自动增加到最多15个线程
第三个参数60 结合第四个参数TimeUnit.SECONDS，表示经过60秒，多出来的线程还没有接到活儿，就会回收，最后保持池子里就10个
第四个参数TimeUnit.SECONDS 如上
第五个参数 new LinkedBlockingQueue() 用来放任务的集合

package multiplethread;

import java.io.File;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class TestThread8 {
    static ThreadPoolExecutor threadPool= new ThreadPoolExecutor(10, 15, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
    public static void search(File file, String search) {

        if (file.isFile()) {
            if(file.getName().toLowerCase().endsWith(".java")){
                SearchFileThread task = new SearchFileThread(file, search);
                threadPool.execute(task);
            }
        }
        if (file.isDirectory()) {
            File[] fs = file.listFiles();
            for (File f : fs) {
                search(f, search);
            }
        }
    }

    public static void main(String[] args) {
        File folder =new File("D:\\Workspaces\\IDEA\\leetcode\\src\\project");
        search(folder,"Magic");
    }
}