Java同时执行多个线程(优雅的进行线程池创建)

发表于 | 分类于 | | 阅读量 次

有时候我们会遇到这样的场景，需要通过多线程同时去对某些信息进行处理然后再进行开展后续的业务，这时候就需要用到多线程来同时并发处理这些数据
其实多线程处理的方式有很多，线程池，自定义线程等等，但是需要同时执行，所以这里用了线程池和CountDownLatch这个类来进行处理

其实思路很简单，首先通过线程池划分好线程明细，然后通过线程池的submit进行处理，同时每一个线程处理好之后通过countDownLatch.countDown()方法将结果给汇总，最后几个线程都处理好了之后进行释放

代码Demo如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
package com.example.demo;

import java.util.concurrent.*;

/**
 * @author fueen
 * @date 2021/3/4 14:32
 * CountDownDemo
 */
public class CountDownDemo {
    
    
    public static void main(String[] args) {
        
        
        CountDownLatch countDownLatch = new CountDownLatch(5);
        //线程池的创建方式推荐使用ThreadPoolExecutor,这也是阿里官方推荐的方式,这样可以避免线程过多导致内存占用一直增加的问题
        ExecutorService threadPool = new ThreadPoolExecutor(
                5,
                5,
                1,
                TimeUnit.MILLISECONDS,
                new LinkedBlockingQueue<Runnable>());
        for (int i = 0; i < 5; i++) {
            int finalI = i;
            threadPool.submit(()->{
                try {
                    System.out.println("----线程"+ finalI+"启动时间为"+System.currentTimeMillis());
                    //后续在此处进行业务处理
                }finally {
                    countDownLatch.countDown();
                }
            });
        }
        //关闭线程处理
        try {
            countDownLatch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        //关闭线程池
        threadPool.shutdown();
    }
    
}

运行结果可以看到他们几乎是同时进行处理的

在这里插入图片描述

注意事项:

在创建线程池的时候，如果这个线程池运行次数非常频繁的话，尽量不要通过Executors这个类下面的方法来创，例如Executors.newCachedThreadPool()这样的方法，这样很有可能会导致线程数量堆积导致内存猛增甚至奔溃，这是笔者经历过得血泪教训。建议通过new ThreadPoolExecutor()这种方式来创建线程并且对线程的详细内容进行配置，这也是阿里官方推荐的创建方式。还有要注意的是线程使用后一定要进行关闭！！

❤赏点钱让我买杯快乐水8❤