高端网站建设青岛优化网站排名推荐公司

一、多线程的作用

1. 多个任务并行执行可以提升效率
2. 异步，让与主业务无关的逻辑异步执行，不阻塞主业务

二、问题描述

1. insertSelective()方法是一个并发度比较高的业务，主要是插入task到任务表里，新建task，并且insertSelective()是有可能在一个事务里的。
2. 圈住的部分，是判断插入的task的id是否达到了一定程度，如果是，就执行建表的逻辑。
3. 这里用异步是因为，checkIfCreateTable方法与主业务无关，避免insertSelective()等待checkIfCreateTable执行，并且如果checkIfCreateTable产生了异常，也不会让insertSelective()回滚。
4. 我的executor是这样定义的: ExecutorService executor = Executors.newFixedThreadPool(10).写的时候也没多想就这样定义了。

问题：

1. checkIfCreateTable()方法其实并不需要每次都要执行（业务是：当task的id超过范围的时候，新建一张表作为用来存放以后的task的数据表，因此加了锁，也不需要每次都强制进去执行，也就是说checkIfCreateTable只要被触发了就行了）。因此当并发度很高的时候，比如要插入150个task，那么executor会向线程池里提交150个任务，如果工作队列满了，newFixedThreadPool()的拒绝策略是抛出异常，因此当并发很高的时候会抛出很多异常。
2. 我们可能会想到，将newFixedThreadPool的线程数设置大一点，但多少算大呢？
3. 此外，在项目中已经存在了一个配置好的TaskPoolExecutor了，这个是用来执行业务中创建的task的，那么，能把executor换成项目里定义好的TaskPoolExecutor吗
4. 问题2治标不治本，我们的需求其实就是让逻辑正常运行，但是不要无休止的抛出异常；问题3的答案是不行，因为TaskPoolExecutor是用在执行task这个业务里的，如果让他来执行checkIfCreateTable这个建表业务，会挤压主业务的并发能力。
5. 还有一个目的就是，checkIfCreateTable只要被触发了就行了，不用无休止的每次都要执行，更别说还要排在工作队列外到抛异常的程度了。因此我们可以定义一个线程池，这个线程池的线程数只有一个，工作队列的长度为2-3个，拒绝策略为忽略掉多出来的任务。这样也满足了能够触发checkIfCreateTable，且不会消耗很多资源来执行，也不会抛出异常。
6. 建议看看newFixedThreadPool()的源码，是用ThreadPoolExecutor来初始化的。

三、结论

当使用xx池时，要关注这是用来做什么业务的。多个业务能否用相同的吗？业务之间会互相影响吗？开多线程的作用？