线程池遍历全部目录

public class scan {
    private final Lock watchLock = new ReentrantLock();
    @Resource(name = "pool")
    private ThreadPoolExecutor pool=new ThreadPoolExecutor(3000,6000,5,TimeUnit.MINUTES,new LinkedBlockingQueue<Runnable>(), new ThreadPoolExecutor.DiscardPolicy());;
    private ArrayList<File> imgDirs;
    private long allTasks = 0;
    private long complatedTasks = 0;
    private ReentrantReadWriteLock lockAll = new ReentrantReadWriteLock();
    private ReentrantReadWriteLock lockComplate = new ReentrantReadWriteLock();
public static void main(String[] args) {
    scan utilScan = new scan();
    System.out.println(Arrays.toString(utilScan.scanLocalDir().toArray()));
}

public List&lt;File&gt; scanLocalDir() {
    imgDirs = new ArrayList&lt;File&gt;();
    File[] roots = File.listRoots();
    try {
        lockAll.writeLock().lock();
        for (File root : roots) {
            pool.submit(new FindDirRunable(root));
            allTasks++;
        }
    } finally {
        lockAll.writeLock().unlock();
    }
    long timestart = System.currentTimeMillis();
    while (complatedTasks &lt; 7000) {
        //死循环监视是否结束，目前还有问题
        System.out.print(&quot;allTasks = &quot; + allTasks);
        System.out.print(&quot;  complatedTasks = &quot; + complatedTasks);
        System.out.print(&quot;  getQueue() = &quot; + pool.getQueue().size());
        System.out.print(&quot;  getActiveCount() = &quot; + pool.getActiveCount());
        System.out.println(&quot;  getCompletedTaskCount() = &quot; + pool.getCompletedTaskCount());
        try {
            Thread.sleep(1);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    ThreadPool.pool.shutdownNow();
    System.out.println(&quot;end&quot;);
    System.out.println(System.currentTimeMillis()-timestart);
    System.out.print(&quot;allTasks = &quot; + allTasks);
    System.out.print(&quot;  complatedTasks = &quot; + complatedTasks);
    System.out.print(&quot;  getQueue() = &quot; + pool.getQueue().size());
    System.out.print(&quot;  getActiveCount() = &quot; + pool.getActiveCount());
    System.out.println(&quot;  getCompletedTaskCount() = &quot; + pool.getCompletedTaskCount());
    return imgDirs;
}

private class FindDirRunable implements Runnable {
    private final File dir;

    FindDirRunable(File dir) {
        this.dir = dir;
    }

    @Override
    public void run() {

//            System.out.println(dir);

try {

File[] dirs = dir.listFiles();

boolean isImgDir = false;

if (dirs != null) {

for (File each : dirs) {//遍历文件夹下的东西

if (each.isFile()) {

if (!isImgDir) {//判断文件夹里有没有图片

String[] temp = each.getName().split("\.");

//                                System.out.println(Arrays.toString(temp));

String type = temp[temp.length - 1];

if (Dict.imgTypes.contains(type.toLowerCase())) {

isImgDir = true;

imgDirs.add(dir);

}

}

} else if (each.isDirectory()) {//递归遍历文件夹

pool.submit(new FindDirRunable(each));

try {

lockAll.writeLock().lock();

allTasks++;

} finally {

lockAll.writeLock().unlock();

}

}

}

}
        } finally {
            //同步加 完成的任务数
            try {
                lockComplate.writeLock().lock();
                complatedTasks++;
            } finally {
                lockComplate.writeLock().unlock();
            }

//                watchLock.notify();//每完成一个任务就唤醒主循环判断是不是所有任务都执行完了

}

}

}
;

}