有时候我们会遇到这样的场景,需要通过多线程同时去对某些信息进行处理然后再进行开展后续的业务,这时候就需要用到多线程来同时并发处理这些数据
其实多线程处理的方式有很多,线程池,自定义线程等等,但是需要同时执行,所以这里用了线程池和CountDownLatch这个类来进行处理
其实思路很简单,首先通过线程池划分好线程明细,然后通过线程池的submit进行处理,同时每一个线程处理好之后通过countDownLatch.countDown()方法将结果给汇总,最后几个线程都处理好了之后进行释放
代码Demo如下:
1 | package com.example.demo; |
运行结果可以看到他们几乎是同时进行处理的
注意事项:
在创建线程池的时候,如果这个线程池运行次数非常频繁的话,尽量不要通过Executors这个类下面的方法来创,例如Executors.newCachedThreadPool()这样的方法,这样很有可能会导致线程数量堆积导致内存猛增甚至奔溃,这是笔者经历过得血泪教训。建议通过new ThreadPoolExecutor()这种方式来创建线程并且对线程的详细内容进行配置,这也是阿里官方推荐的创建方式。还有要注意的是线程使用后一定要进行关闭!!