多线程分布式处理

Posted 2021-04-21 有意思的程序员

在日常程序开发过程中，我们经常会遇到一个某一个环节非常耗时的，而且这个环节是业务所绕不开的，我的需求是如何高效率的处理这个耗时的环节，多线程是我们可以考虑的一个选择，开启多个线程去处理这个耗时的任务会大大提升我们程序的效率。

需求：将一个文件夹下的文件拷贝到另一个目录

单线程拷贝：

耗时：

每一个文件开启一个线程

线程实现类

文件拷贝方法

结果：

这里需要注意的是磁盘的利用率，如果一个线程的io占用已经很高了，那么再开启线程的效果也是不明显的

多线程拷贝流程图

知识点：

CountDownLatch是什么

CountDownLatch是在java1.5被引入的，跟它一起被引入的并发工具类还有CyclicBarrier、Semaphore、ConcurrentHashMap和BlockingQueue，它们都存在于java.util.concurrent包下。CountDownLatch这个类能够使一个线程等待其他线程完成各自的工作后再执行。例如，应用程序的主线程希望在负责启动框架服务的线程已经启动所有的框架服务之后再执行。

CountDownLatch是通过一个计数器来实现的，计数器的初始值为线程的数量。每当一个线程完成了自己的任务后，计数器的值就会减1。当计数器值到达0时，它表示所有的线程已经完成了任务，然后在闭锁上等待的线程就可以恢复执行任务。