记录下spring使用线程池的配置

梦里梦外; 2022-05-22 04:41 130阅读 0赞

#### spring的配置文件中配置线程池 ####

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xmlns:task="http://www.springframework.org/schema/task" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.0.xsd" default-autowire="byName" default-lazy-init="false">
    
    
        <bean id="configProperties" class="org.springframework.beans.factory.config.PropertiesFactoryBean">
            <property name="locations">
                <list>
                    <value>File:/home/paydubbo/etc/config.properties
                    </value>
                </list>
            </property>
        </bean>
    
    
        
        <bean id="propertyConfig" class="com.imobpay.base.config.PropertyPlaceholderConfigurerExt">
            <property name="locations">
                <list>
                    <value>File:/home/paydubbo/etc/config.properties
                    </value>
                </list>
            </property>
        </bean>
    
    
        
        <context:component-scan annotation-config="true" base-package="com.imobpay.base.*" />
        
        <context:annotation-config />
    
        
        <task:annotation-driven executor="taskExecutor" scheduler="scheduler" />
    
        <task:scheduler id="scheduler" pool-size="10" />
        
        
    
    
        
        
        <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
            <property name="corePoolSize" value="${taskExecutor.corePoolSize}" />
            <property name="maxPoolSize" value="${taskExecutor.maxPoolSize}" />
            <property name="keepAliveSeconds" value="${taskExecutor.keepAliveSeconds}" />
            <property name="queueCapacity" value="${taskExecutor.queueCapacity}" />
            <property name="allowCoreThreadTimeOut" value="true"></property>
            
            <property name="rejectedExecutionHandler">
                <bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy" />
            </property>
        </bean>
        
        <bean id="taskExecutorBatch" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
            <property name="corePoolSize" value="${taskExecutorBatch.corePoolSize}" />
            <property name="maxPoolSize" value="${taskExecutorBatch.maxPoolSize}" />
            <property name="keepAliveSeconds" value="${taskExecutorBatch.keepAliveSeconds}" />
            <property name="queueCapacity" value="${taskExecutorBatch.queueCapacity}" />
            <property name="allowCoreThreadTimeOut" value="true"></property>
            
            <property name="rejectedExecutionHandler">
                <bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy" />
            </property>
        </bean>
        
        <bean id="timeJob" class="com.imobpay.base.services.impl.ServicesTimeJob"></bean>
    
    
        <task:scheduled-tasks>
            
            <task:scheduled ref="timeJob" method="printlnThreadPoolInfo" cron="${task.printlnThreadPoolInfo}" />
        </task:scheduled-tasks>
    
    
    </beans>

#### spring可以使用@Async(“taskExecutor”)来执行异步操作 ####

@Async(“taskExecutor”)里面的taskExecutor就是上面配置线程池的id

@Async("taskExecutor")
        @Override
        public void onMessage(Message message) {
        //doSomething...........
        }

#### 记录下java里面线程池的书写 ####

/** * 设置清算机构初始化去线程池 */
        ThreadPoolExecutor settleTaskExecutor;
         settleTaskExecutor = new ThreadPoolExecutor(settleList.size(), Runtime.getRuntime().availableProcessors() * settleList.size(), 200, TimeUnit.MILLISECONDS,
                        new LinkedBlockingQueue(300), new ThreadPoolExecutor.DiscardOldestPolicy());
                settleTaskExecutor.allowCoreThreadTimeOut(true);