线程池demo

使用场景

java中经常需要用到多线程来处理一些业务，我们非常不建议单纯使用继承Thread或者实现Runnable接口的方式来创建线程，那样势必有创建及销毁线程耗费资源、线程上下文切换问题。同时创建过多的线程也可能引发资源耗尽的风险，这个时候引入线程池比较合理，方便线程任务的管理。java中涉及到线程池的相关类均在jdk1.5开始的java.util.concurrent包中，涉及到的几个核心类及接口包括：Executor、Executors、ExecutorService、ThreadPoolExecutor、FutureTask、Callable、Runnable等。 

创建线程池的方法 

通过Executors类创建
Executors.newFixedThreadPool
创建一个固定大小的线程池，可控制并发的线程数，超出的线程会在队列中等待
Executors.newCachedThreadPool
创建一个可缓存的线程池，若线程数超过处理所需，缓存一段时间后会回收，若线程数不够，则新建线程
Executors.newSingleThreadExecutor
创建单个线程数的线程池，它可以保证先进先出的执行顺序
Executors.newScheduledThreadPool
创建一个可以执行延迟任务的线程池
Executors.newSingleThreadScheduledExecutor
创建一个单线程的可以执行延迟任务的线程池
Executors.newWorkStealingPool
创建一个抢占式执行的线程池（任务执行顺序不确定）JDK 1.8 中添加
通过ThreadPoolExecutor类创建

Demo

  private void init()
    {
        int processors = Runtime.getRuntime().availableProcessors();//当前可用线程
        this.helathCodeService = Executors.newFixedThreadPool(processors, new NamedThreadFactory("XX获取线程池"));
    }

具体使用

  //定义了一个数 1
        CountDownLatch count = new CountDownLatch(1);
                this.helathCodeService.submit(() -> {
                    try {
                        for (Map tourist : touristListThread){
                            if (tourist.get("certiNo") != null && tourist.get("name") != null)
                            {
                                Map resultMap  = healthCodeUtils.getCode( tourist.get("name").toString(),tourist.get("certiNo").toString());

                                if (resultMap.get("riskAssessmentGrade")!=null)
                                {
                                    String code = resultMap.get("riskAssessmentGrade").toString();
                                    tourist.put("healthCode", codeMap.get(code));
                                }else {
                                    tourist.put("healthCode",codeMap.get("11"));
                                }

                            }else {
                                tourist.put("healthCode",codeMap.get("11"));
                            }
                        }
                    } catch (Exception e) {
                        LOGGER.info("健康码获取异常");
                    } finally {
                        count.countDown();
                    }
            });
            try {
                count.await();
            }catch (Exception e)
            {
                LOGGER.info("健康码线程唤醒异常");
            }

  线程池中的 *** 作赋值大家会觉得执行完之后去没有赋值，解决办法加上CountDownLatch等待当前线程执行完毕之后在执行主线程

CountDownLatch允许一个或者多个线程去等待其他线程完成 *** 作。