Spring中线程池的用法

我不是女神ヾ 2022-06-14 11:09 246阅读 0赞

> 多线程并发处理起来通常比较麻烦，如果你使用spring容器来管理业务bean，事情就好办了多了。spring封装了java的多线程的实现，简化了开发。

### 简单的Hello程序 ###

#### 需要执行的线程类 ####

一般是对于业务的封装.将具体的业务逻辑放到，线程内执行。

public class MessagePrinterTask implements Runnable { 
        private String message;
    
        public MessagePrinterTask() {
    
        }
    
        public MessagePrinterTask(String message) {
            this.message = message;
        }
    
        public void run() {
            try {
                Thread.sleep(3000);
                System.out.println(message);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
    
        }
    
        @Override
        public String toString() {
            return "MessagePrinterTask [message=" + message + "]";
        }
    
    }

#### 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:context="http://www.springframework.org/schema/context" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd">
    
        
        <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
            
            <property name="corePoolSize" value="10" />
            
            <property name="maxPoolSize" value="50" />
            
            <property name="queueCapacity" value="100" />
            
            <property name="keepAliveSeconds" value="300" />
            
            
            
        </bean>
    
        
        <bean id="messagePrinterTask" class="com.test.sping.thread.MessagePrinterTask" />
    
    </beans>

#### 测试代码 ####

*  测试代码

import java.util.concurrent.Executor;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    public class ThreadTest { 
        public static void main(String[] args) {
    
            ApplicationContext appContext = new ClassPathXmlApplicationContext("applicationContext.xml");
            Executor executor = (Executor) appContext.getBean("taskExecutor");
    
            for (int i = 0; i < 10; i++) {
                MessagePrinterTask mTask = new MessagePrinterTask("Message data is " + i);
                executor.execute(mTask);
            }
    
            System.out.println("I am from Main Thread ...");
        }
    }

*  测试代码的运行结果

I am from Main Thread ...
    Message data is 5
    Message data is 7
    Message data is 6
    Message data is 8
    Message data is 4
    Message data is 9
    Message data is 0
    Message data is 3
    Message data is 1
    Message data is 2

### 在Spring容器启动的时候,启动一个线程 ###

#### 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:context="http://www.springframework.org/schema/context" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd">
    
        
        <bean id="scheduledThread" class="com.test.sping.thread.ScheduledThread" />
    
        
        <bean id="springScheduleExecutorTask" class="org.springframework.scheduling.concurrent.ScheduledExecutorTask">
            
            <property name="runnable" ref="scheduledThread" />
            
            <property name="delay" value="5000" />
            
            <property name="period" value="2000" />
        </bean>
    
       
        <bean id="springScheduledExecutorFactoryBean" class="org.springframework.scheduling.concurrent.ScheduledExecutorFactoryBean">
            <property name="scheduledExecutorTasks">
                <list>
                    <ref bean="springScheduleExecutorTask" />
                </list>
            </property>
        </bean>
    
    
    </beans>

#### 业务线程 ####

public class ScheduledThread implements Runnable { 
    
        @Override
        public void run() {
    
            while (true) {
                try {
                    Thread.sleep(5000);
                    System.out.println(" I am from ScheduledThread ...");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }

#### 测试代码 ####

import org.springframework.context.support.ClassPathXmlApplicationContext;
    public class ScheduledThreadTest {
        public static void main(String[] args) {
    
            ClassPathXmlApplicationContext appContext = new ClassPathXmlApplicationContext("applicationContext-scheduled.xml");
    
            try {
                Thread.sleep(Integer.MAX_VALUE);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }