Spring 线程池使用

Love The Way You Lie 2022-05-08 09:44 162阅读 0赞

Spring 中默认自带线程池*org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor，一般有可以直接使用，这是时候使用的是默认的配置，直接使用*@Autowired注入使用

@Autowired  
    private ThreadPoolTaskExecutor poolTaskExecutor;

package com.timespark.door.test;
    
    
    
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
    import org.springframework.test.context.ContextConfiguration;
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
    
    /**
     * @author summer
     * @version 创建时间：2018年10月6日 下午3:52:15 类说明
     */
    @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration(locations = { "classpath:spring-context*.xml", "classpath*:ActiveMQ.xml" })
    public class SummerTest {
    
        @Autowired
        private ThreadPoolTaskExecutor poolTaskExecutor;
    
        @Test
        public void testThreadPool() {
            poolTaskExecutor.execute(new Runnable() {
    
                @Override
                public void run() {
                    System.out.println("要做的事情.......");
    
                }
            });
        }
    
    }

另外一种放方式是自己定义线程池的属性 ，通过xml文件配置 ，然后通过@Autowired注入，此时注入的变量名要和xml中配置的id一致，否则 Spring 容器中会有两个线程池，一个是默认的，一个是配置的

<bean id="poolTaskExecutor"  class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
           
           <property name="corePoolSize" value="5" />
           
           <property name="maxPoolSize" value="50" />
           
           <property name="queueCapacity" value="2000" />
           
           <property name="keepAliveSeconds" value="100" />
           
           <property name="rejectedExecutionHandler">
               
               
               
               
               <bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy" />
           </property>
        </bean>

最后一种是基于JDK的线程池ThreadPooleExecutor

ThreadPoolExecutor executor = new ThreadPoolExecutor(50, 100, 200, TimeUnit.MILLISECONDS,
                        new ArrayBlockingQueue<Runnable>(500));
             executor.execute(new Runnable() {
                
                @Override
                public void run() {
                    // TODO Auto-generated method stub
                    
                }
            });