Java线程池ThreadPoolTaskExecutor使用

1. 定义taskExecutor bean

    <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
        <!-- 线程池维护线程的最少数量 -->
        <property name="corePoolSize" value="5"/>
        <!-- 允许的空闲时间 -->
        <property name="keepAliveSeconds" value="200"/>
        <!-- 线程池维护线程的最大数量 -->
        <property name="maxPoolSize" value="10"/>
        <!-- 缓存队列 -->
        <property name="queueCapacity" value="20"/>
        <!-- 对拒绝task的处理策略 -->
        <property name="rejectedExecutionHandler">
            <bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy"/>
        </property>
    </bean>

2.代码中注入taskExecutor

 @Autowired
    private ThreadPoolTaskExecutor taskExecutor;

3. 业务代码中使用

      try {
            taskExecutor.execute(new Runnable() {
                @Override
                public void run() {
                    logger.info("save push log ......");
                    jcXtZnxxMapper.insert(jcXtZnxx);
                }
            });
        } catch (Exception e) {
            e.printStackTrace();
        }