线程池小计

Posted 2020-11-18 shz365

线程池的管理过程：首先创建一个线程池，然后根据任务的数量逐步将线程增大到corePoolSize，如果此时仍有任务增加，则放置到workQueue中，直到workQueue爆满为止，然后继续增加池中的线程数量（增强处理能力），最终达到maxinumPoolSize。那如果此时还有任务要增加进来呢？这就需要handler来处理了，或者丢弃新任务，或者拒绝新任务，或者挤占已有的任务。在任务队列和线程池都饱和的情况下，一旦有线程处于等待（任务处理完毕，没有新任务）状态的时间超过keepAliveTime，则该线程终止，也就是说池中的线程数量会逐渐降低，直至为corePoolSize数量为止。

newFixedThreadPool 固定线程池使用

场景介绍

    在一个业务逻辑中需要同时生成7份合同（pdf）格式，在生成合同的同时，
    不仅需要调用一些外部接口去获取合同中的参数信息，而且还需要调用个人签章
    和企业签章去合同中生成。这样调用一个合同的时间就很长了，一个大概也需要3-4s，
    那么如果顺序执行7个，完成就需要20几s。这样接口响应就会需要很长时间来完成。

 

解决办法

    1／异步调用生成合同接口
    2／在异步调用接口的同时，采用线程池的方式同时创建7个线程去同时生成7个合同。
    这样既省时间又可以很快给用户作出响应。

 

ExecutorService executor = Executors.newFixedThreadPool(7);

        Future<Boolean> f = executor.submit(() -> {
            try{
                return generatePuchase(contractNo);

            }catch (Exception e){
                logger.error("生成咨询服务协议失败",e);
                return false;
            }
        });

        Future<Boolean> f1=executor.submit(() -> {
            try{
                return generateEntrustment(contractNo);
            }catch (Exception e){
                logger.error("生成划扣协议书失败",e);
                return false;
            }
        });

        Future<Boolean> f2=executor.submit(() -> {
            try{
                return  generatePromise(contractNo);
            }catch (Exception e){
                logger.error("生成用户承诺函失败",e);
                return  false;
            }

        });

        Future<Boolean> f3=executor.submit(() -> {
            try{
                return generateUserConfirm(contractNo);
            }catch (Exception e){
                logger.error("生成用户确认书失败",e);
                return  false;
            }
        });

        Future<Boolean> f4=executor.submit(() -> {
            try{
                return  generateTrust(contractNo);

            }catch (Exception e){
                logger.error("生成委托协议书失败",e);
                return  false;
            }
        });
        Future<Boolean> f5=executor.submit(() -> {
            try{
                return   generateHjConfirm(contractNo);

            }catch (Exception e){
                logger.error("生成用户确认书失败",e);
                return  false;
            }
        });

        Future<Boolean> f6=executor.submit(() -> {
            try{
                return  generateLend(contractNo);

            }catch (Exception e){
                logger.error("生成借款合同失败",e);
                return  false;
            }
        });


        for(;;){
            if(f.isDone() && f1.isDone() && f2.isDone() && f3.isDone() && f4.isDone() && f5.isDone() && f6.isDone()){
                try {
                    if(f.get() && f1.get() && f2.get() && f3.get() && f4.get() && f5.get() && f6.get() ){
                        //7个合同同时生成完成后再调用签约借款2
                        //调用签约接口
                        String signUrl=insideServiceUrl+CommonConstants.INSIDE_FR_SIGN_URL+orderId;
                        logger.info("调用签约地址为{}",signUrl);
                        CommonResponseResult commonResponseResult=oAuth2RestTemplate.getForObject(signUrl,CommonResponseResult.class);
                        if("00000".equals(commonResponseResult.getCode())){
                            logger.info("订单ID为{}调用签约接口成功",orderId);
                        }else if("99999".equals(commonResponseResult.getCode())){
                            logger.info("订单ID为{}调用签约接口失败",orderId);
                        }
                        break;
                    }

                } catch (InterruptedException e) {
                    logger.error("线程执行出错1",e);
                } catch (ExecutionException e) {
                    logger.error("线程执行出错2",e);

                }
            }
        }

简单解析：for循环需要持续循环等待7个线程全部执行完毕，
并且返回结果全部为true时才去调用签约接口。亲测没有问题，很快
其中的：Future.get()    Waits if necessary for the computation to complete, and then retrieves its result.