码迷,mamicode.com
首页 > 编程语言 > 详细

记录一次线程池的在项目中的实际应用,讲解一下线程池的配置和参数理解。

时间:2018-07-01 21:22:16      阅读:322      评论:0      收藏:0      [点我收藏+]

标签:tco   hashmap   cut   key   get   响应   处理   匿名   insert   

前言:最近项目中与融360项目中接口对接,有反馈接口(也就是我们接收到请求,需要立即响应,并且还要有一个接口推送给他们其他计算结果),推送过程耗时、或者说两个接口不能是同时返回,有先后顺序。

这时我想到了把自己Controller立即返回接受成功,中间添加一个新的线程去做其他耗时的操作(线程池配置和参数测试讲解请阅读第5步)。

1、Controller代码如下:

@Autowired
private CallThreadDemo worker;
@RequestMapping("/bandBankConfirm2")
    public void bandBankConfirm2(String jsonString) {
        System.out.println("controller开始--------------");
    //这里是需要调用第三方的接口传入参数 String method
= "is.api.v3.order.bindcardfeedback"; Map<String, Object> map = new HashMap<>(); map.put("order_no", "254986512848973"); map.put("bind_status", 1); map.put("reason", "");     //这里开始调用线程池的方法 worker.callRong360(method, map); System.out.println("controller end --------------");
    //renderJson这个方法是jfinal的,可以理解为@ReponseBody 需要return的操作了
    renderJson("接口调用完毕");   
}
2、调用线程池的方法 CallThreadDemo 类代码:
@Component
public class CallThreadDemo {

    @Autowired
    private ThreadPoolTaskExecutor executor;
    @Autowired
    private ServiceTest serviceTest;

    public void callRong360(final String method, final Map<String, Object> map) {
        //这个类是我封装的抽象类,里面有一个公共方法,具体代码下面有
        ServiceParent callRong360Method = new ServiceParent() {
            @Override
            public void run() {
                try {
                    Thread.sleep(20000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("线程开始-------------");
          //这里调用第三方公用接口 JSONObject result
= callBandBankMethod(method, map);

          //这里调用service方法,实现自己的业务逻辑 serviceTest.insertUser(
"111", "222222");
System.out.println(result); System.out.println(
"线程结束-------------"); } }; executor.execute(callRong360Method); System.out.println("当前活动线程数:"+ executor.getActiveCount()); System.out.println("核心线程数:"+ executor.getCorePoolSize()); System.out.println("总线程数:"+ executor.getPoolSize()); System.out.println("最大线程池数量"+executor.getMaxPoolSize()); System.out.println("线程处理队列长度"+executor.getThreadPoolExecutor().getQueue().size()); }

3、封装的抽象类代码如下:

public abstract class ServiceParent implements Runnable {

    public JSONObject callBandBankMethod(String method, Map<String, Object> map) {
//这个方法是调用三方的接口,公用部分
// //输入 参数如下 : // Map<String, Object> map = new HashMap<>(); // map.put("order_no", "254986512848973"); // map.put("bind_status", 1); // map.put("reason", ""); // net.sf.json.JSONObject ret = callRong360Method.callBandBankMethod("is.api.v3.order.bindcardfeedback", map); // // // 异常情况输出参数 为 null: OpenapiClient openapiClient = new OpenapiClient(); openapiClient.setMethod(method); for (Map.Entry<String, Object> entry : map.entrySet()) { openapiClient.setField(entry.getKey(), String.valueOf(entry.getValue())); } net.sf.json.JSONObject ret = null; try { ret = openapiClient.execute(); } catch (Exception e) { e.printStackTrace(); System.out.println("调用反馈接口异常---->" + e.getMessage()); } return ret; }   //这里定义为抽象方法,创建匿名内部类或者继承类必须实现 public abstract void run();

4、ServiceTest接口方法如下:

@Service
public class ServiceTest {

    @Autowired
    private BankMapper bankMapper;

    @Transactional(rollbackFor = {Exception.class})
    public void insertUser(String s, String s1) {
        bankMapper.insertUser(s, s1);

         //这里创建异常,测试事务。已测试,事务生效
        int i = 1 / 0;
    }
}

以上四步,成功在调用Controller方法立即返回结果,也实现了另外的一个线程去调用三方接口返回信息,并且实现了自己的业务逻辑。

5、接着我们继续说明一下线程池对应配置和参数说明,这里我们通过测试来说明参数的作用(corePoolSize 核心线程数量,maxPoolSize 最大线程数,queueCapacity 处理队列)

  threadpool.corePoolSize=5
  threadpool.keepAliveSeconds=200
  threadpool.maxPoolSize=10
  threadpool.queueCapacity=2
  <!-- 线程池 -->
    <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
        <property name="corePoolSize" value="${threadpool.corePoolSize}" />
        <property name="keepAliveSeconds" value="${threadpool.keepAliveSeconds}" />
        <property name="maxPoolSize" value="${threadpool.maxPoolSize}" />
        <property name="queueCapacity" value="${threadpool.queueCapacity}" />
    </bean>
        <!--请在bean xsd中配置task-->
    <task:annotation-driven executor="taskExecutor" />
    

 

下面贴出测试输出的日志信息:controller开始--------------

当前活动线程数:1
核心线程数:5
总线程数:1
最大线程池数量10
线程处理队列长度0
controller  end --------------

controller开始-------------- 当前活动线程数:2 核心线程数:5 总线程数:2 最大线程池数量10 线程处理队列长度0 controller end --------------

controller开始-------------- 当前活动线程数:3 核心线程数:5 总线程数:3 最大线程池数量10 线程处理队列长度0 controller end --------------

controller开始-------------- 当前活动线程数:4 核心线程数:5 总线程数:4 最大线程池数量10 线程处理队列长度0 controller end --------------

controller开始-------------- 当前活动线程数:5 核心线程数:5 总线程数:5 最大线程池数量10 线程处理队列长度0 controller end --------------

controller开始-------------- 当前活动线程数:5---------------》因为放入了队列中,此处活动线程数还是5 核心线程数:5 总线程数:5 最大线程池数量10 线程处理队列长度1 -------------》这里达到了最大的核心线程数量 corePoolSize=5,开始放入处理队列中
queueCapacity=2
controller end --------------
controller开始--------------
当前活动线程数:5
核心线程数:5
总线程数:5
最大线程池数量10
线程处理队列长度2 ---------------》继续放入队列中,达到了最大队列数量2
controller  end --------------

controller开始-------------- 当前活动线程数:6-----------------》这里因为达到了最大队列数量,所以继续创建线程去执行,一直到最后到最大线程数量 核心线程数:5 总线程数:6 最大线程池数量10 线程处理队列长度2 controller end --------------

controller开始-------------- 当前活动线程数:7 核心线程数:5 总线程数:7 最大线程池数量10 线程处理队列长度2 controller end --------------

controller开始-------------- 当前活动线程数:8 核心线程数:5 总线程数:8 最大线程池数量10 线程处理队列长度2 controller end --------------

controller开始-------------- 当前活动线程数:9 核心线程数:5 总线程数:9 最大线程池数量10 线程处理队列长度2 controller end --------------

controller开始-------------- 当前活动线程数:10 --------------》这里活动线程数量达到了最大线程池数量 核心线程数:5 总线程数:10 最大线程池数量10 线程处理队列长度2 controller end --------------

controller开始-------------- 2018-07-01 20:23:19 -----------------》这里继续调用,因为最大线程池数量和队列中都已经到了最大值,抛出了异常 [] [] [WARN]-[Thread: qtp1276504061-60]-[org.springframework.web.servlet.handler.AbstractHandlerExceptionResolver.logException()]: Handler execution resulted in exception org.springframework.core.task.TaskRejectedException: Executor [java.util.concurrent.ThreadPoolExecutor@17d95b77[Running, pool size = 10, active threads = 10, queued tasks = 2, completed tasks = 0]] did not accept task: com.fastx.cooperate.rong360.rong.service.CallThreadDemo$1@5fa6bf1 at org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor.execute(ThreadPoolTaskExecutor.java:245) at com.fastx.cooperate.rong360.rong.service.CallThreadDemo.callRong360(CallThreadDemo.java:43)

这样,通过输出的日志,我们可以很容易的理解了各个参数的作用。

 

记录一次线程池的在项目中的实际应用,讲解一下线程池的配置和参数理解。

标签:tco   hashmap   cut   key   get   响应   处理   匿名   insert   

原文地址:https://www.cnblogs.com/liran123/p/9251249.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!