文档章节

Spring线程池开发实战及使用spring注解

z
 zahschusheng
发布于 2015/10/27 11:13
字数 1020
阅读 12303
收藏 11

本文提供了三个Spring多线程开发的例子,由浅入深,由于例子一目了然,所以并未做过多的解释。诸位一看便知。

前提条件:

1)在Eclipse创建一个Java项目,我取名为SpringThreadDemo。
2)项目所需的JAR包如图所示:
 

下面开始。

 

注:项目源码已经托管到GitHub,地址:https://github.com/chszs/SpringThreadDemo

例子1:Spring结合Java线程。

通过继承Thread创建一个简单的Java线程,然后使用@Component让Spring容器管理此线程,Bean的范围必须是prototype,因此每个请求都会返回一个新实例,运行每个单独的线程。

PrintThread.java

 

[java] view plaincopyprint?

 

  1. package com.chszs.thread;  

  2.   

  3. import org.springframework.stereotype.Component;  

  4. import org.springframework.context.annotation.Scope;  

  5.   

  6. @Component  

  7. @Scope("prototype")  

  8. public class PrintThread extends Thread{  

  9.         @Override  

  10.         public void run(){  

  11.                 System.out.println(getName() + " is running.");  

  12.                 try{  

  13.                         Thread.sleep(5000);  

  14.                 }catch(InterruptedException e){  

  15.                         e.printStackTrace();  

  16.                 }  

  17.                 System.out.println(getName() + " is running again.");  

  18.         }  

  19. }  

 

AppConfig.java

 

 

[java] view plaincopyprint?

 

  1. package com.chszs.config;  

  2.   

  3. import org.springframework.context.annotation.ComponentScan;  

  4. import org.springframework.context.annotation.Configuration;  

  5.   

  6. @Configuration  

  7. @ComponentScan(basePackages="com.chszs.thread")  

  8. public class AppConfig {  

  9. }  

App.java

 

 

[java] view plaincopyprint?

 

  1. package com.chszs;  

  2. import org.springframework.context.ApplicationContext;  

  3. import org.springframework.context.annotation.AnnotationConfigApplicationContext;  

  4.   

  5. import com.chszs.config.AppConfig;  

  6. import com.chszs.thread.PrintThread;  

  7.   

  8. public class App {  

  9.         public static void main(String[] args){  

  10.                 ApplicationContext ctx =   

  11.             new AnnotationConfigApplicationContext(AppConfig.class);  

  12.                 PrintThread printThread1 = (PrintThread)ctx.getBean("printThread");  

  13.                 printThread1.setName("Thread 1");  

  14.                   

  15.                 PrintThread printThread2 = (PrintThread)ctx.getBean("printThread");  

  16.                 printThread2.setName("Thread 2");  

  17.                   

  18.                 PrintThread printThread3 = (PrintThread)ctx.getBean("printThread");  

  19.                 printThread3.setName("Thread 3");  

  20.                   

  21.                 PrintThread printThread4 = (PrintThread)ctx.getBean("printThread");  

  22.                 printThread4.setName("Thread 4");  

  23.                   

  24.                 PrintThread printThread5 = (PrintThread)ctx.getBean("printThread");  

  25.                 printThread5.setName("Thread 5");  

  26.                   

  27.                 printThread1.start();  

  28.                 printThread2.start();  

  29.                 printThread3.start();  

  30.                 printThread4.start();  

  31.                 printThread5.start();  

  32.         }  

  33. }  

 

输出:

Thread 1 is running.
Thread 2 is running.
Thread 4 is running.
Thread 5 is running.
Thread 3 is running.
Thread 2 is running again.
Thread 1 is running again.
Thread 5 is running again.
Thread 4 is running again.
Thread 3 is running again.

 

 

例子2:Spring线程池结合非Spring托管Bean。

 

使用Spring的ThreadPoolTaskExecutor类创建一个线程池。执行线程无需受Spring容器的管理。

PrintTask.java

 

 

[java] view plaincopyprint?

 

  1. package com.chszs.thread;  

  2.   

  3. public class PrintTask implements Runnable{  

  4.         String name;  

  5.         public PrintTask(String name){  

  6.                 this.name = name;  

  7.         }  

  8.         @Override  

  9.         public void run() {  

  10.                 System.out.println(name + " is running.");  

  11.                 try{  

  12.                         Thread.sleep(5000);  

  13.                 }catch(InterruptedException e){  

  14.                         e.printStackTrace();  

  15.                 }  

  16.                 System.out.println(name + " is running again.");  

  17.         }  

  18.           

  19. }  

Spring-Config.xml

 

 

[html] view plaincopyprint?

 

  1. <beans xmlns="http://www.springframework.org/schema/beans"  

  2.         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"   

  3.         xmlns:context="http://www.springframework.org/schema/context"  

  4.         xsi:schemaLocation="http://www.springframework.org/schema/beans  

  5.         http://www.springframework.org/schema/beans/spring-beans-3.1.xsd  

  6.         http://www.springframework.org/schema/context  

  7.         http://www.springframework.org/schema/context/spring-context-3.1.xsd">  

  8.           

  9.         <bean id="taskExecutor"   

  10.         class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">  

  11.                 <property name="corePoolSize" value="5" />  

  12.                 <property name="maxPoolSize" value="10" />  

  13.                 <property name="WaitForTasksToCompleteOnShutdown" value="true" />  

  14.         </bean>  

  15. </beans>  


注意这个Spring配置文件的位置,如图所示:

 



App1.java

 

[java] view plaincopyprint?

 

  1. package com.chszs;  

  2.   

  3. import org.springframework.context.ApplicationContext;  

  4. import org.springframework.context.support.ClassPathXmlApplicationContext;  

  5. import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;  

  6.   

  7. import com.chszs.thread.PrintTask;  

  8.   

  9. public class App1 {  

  10.   

  11.         public static void main(String[] args) {  

  12.                 ApplicationContext ctx =   

  13.             new ClassPathXmlApplicationContext("resources/Spring-Config.xml");  

  14.                 ThreadPoolTaskExecutor taskExecutor =  

  15.             (ThreadPoolTaskExecutor)ctx.getBean("taskExecutor");  

  16.                 taskExecutor.execute(new PrintTask("Thread 1"));  

  17.                 taskExecutor.execute(new PrintTask("Thread 2"));  

  18.                 taskExecutor.execute(new PrintTask("Thread 3"));  

  19.                 taskExecutor.execute(new PrintTask("Thread 4"));  

  20.                 taskExecutor.execute(new PrintTask("Thread 5"));  

  21.                 // 检查活动的线程,如果活动线程数为0则关闭线程池  

  22.                 for(;;){  

  23.                         int count = taskExecutor.getActiveCount();  

  24.                         System.out.println("Active Threads : " + count);  

  25.                         try{  

  26.                                 Thread.sleep(1000);  

  27.                         }catch(InterruptedException e){  

  28.                                 e.printStackTrace();  

  29.                         }  

  30.                         if(count==0){  

  31.                                 taskExecutor.shutdown();  

  32.                                 break;  

  33.                         }  

  34.                 }  

  35.         }  

  36.   

  37. }  

 

输出:

 

Thread 1 is running.
Thread 2 is running.
Thread 3 is running.
Thread 4 is running.
Active Threads : 4
Thread 5 is running.
Active Threads : 5
Active Threads : 5
Active Threads : 5
Active Threads : 5
Active Threads : 5
Thread 4 is running again.
Thread 2 is running again.
Thread 3 is running again.
Thread 1 is running again.
Thread 5 is running again.
Active Threads : 0

作者:chszs,转载需注明。博客主页:http://blog.csdn.net/chszs

例子3:Spring线程池结合Spring托管Bean。


本例仍然使用ThreadPoolTaskExecutor类,并使用@Component注释声明Spring的托管Bean。
下面的例子PrintTask2是Spring的托管Bean,使用@Autowired注释简化代码。

 

PrintTask2.java

 

[java] view plaincopyprint?

 

  1. package com.chszs.thread;  

  2.   

  3. import org.springframework.context.annotation.Scope;  

  4. import org.springframework.stereotype.Component;  

  5.   

  6. @Component  

  7. @Scope("prototype")  

  8. public class PrintTask2 implements Runnable {  

  9.         String name;  

  10.   

  11.         public void setName(String name) {  

  12.                 this.name = name;  

  13.         }  

  14.           

  15.         @Override  

  16.         public void run(){  

  17.                 System.out.println(name + " is running.");  

  18.                 try{  

  19.                         Thread.sleep(5000);  

  20.                 }catch(InterruptedException e){  

  21.                         e.printStackTrace();  

  22.                 }  

  23.                 System.out.println(name + " is running again.");  

  24.         }  

  25. }  

 

AppConfig.java

 

 

[java] view plaincopyprint?

 

  1. package com.chszs.config;  

  2.   

  3. import org.springframework.context.annotation.Bean;  

  4. import org.springframework.context.annotation.ComponentScan;  

  5. import org.springframework.context.annotation.Configuration;  

  6. import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;  

  7.   

  8. @Configuration  

  9. @ComponentScan(basePackages="com.chszs.thread")  

  10. public class AppConfig {  

  11.         @Bean  

  12.         public ThreadPoolTaskExecutor taskExecutor(){  

  13.                 ThreadPoolTaskExecutor pool = new ThreadPoolTaskExecutor();  

  14.                 pool.setCorePoolSize(5);  

  15.                 pool.setMaxPoolSize(10);  

  16.                 pool.setWaitForTasksToCompleteOnShutdown(true);  

  17.                 return pool;  

  18.         }  

  19. }  

 

App2.java

 

 

[java] view plaincopyprint?

 

  1. package com.chszs;  

  2.   

  3. import org.springframework.context.ApplicationContext;  

  4. import org.springframework.context.annotation.AnnotationConfigApplicationContext;  

  5. import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;  

  6.   

  7. import com.chszs.config.AppConfig;  

  8. import com.chszs.thread.PrintTask2;  

  9.   

  10. public class App2 {  

  11.         public static void main(String[] args) {  

  12.                 ApplicationContext ctx =   

  13.             new AnnotationConfigApplicationContext(AppConfig.class);  

  14.                 ThreadPoolTaskExecutor taskExecutor =  

  15.             (ThreadPoolTaskExecutor)ctx.getBean("taskExecutor");  

  16.                   

  17.                 PrintTask2 printTask1 = (PrintTask2)ctx.getBean("printTask2");  

  18.                 printTask1.setName("Thread 1");  

  19.                 taskExecutor.execute(printTask1);  

  20.                   

  21.                 PrintTask2 printTask2 = (PrintTask2)ctx.getBean("printTask2");  

  22.                 printTask2.setName("Thread 2");  

  23.                 taskExecutor.execute(printTask2);  

  24.                   

  25.                 PrintTask2 printTask3 = (PrintTask2)ctx.getBean("printTask2");  

  26.                 printTask3.setName("Thread 3");  

  27.                 taskExecutor.execute(printTask3);  

  28.                   

  29.                 for(;;){  

  30.                         int count = taskExecutor.getActiveCount();  

  31.                         System.out.println("Active Threads : " + count);  

  32.                         try{  

  33.                                 Thread.sleep(1000);  

  34.                         }catch(InterruptedException e){  

  35.                                 e.printStackTrace();  

  36.                         }  

  37.                         if(count==0){  

  38.                                 taskExecutor.shutdown();  

  39.                                 break;  

  40.                         }  

  41.                 }  

  42.         }  

  43.   

  44. }  

 

输出:

 获取【下载地址】 【企业框架源码】 SpringMVC mybatis or hibernate ehcache二级缓存maven非和maven版本

Thread 1 is running.
Thread 2 is running.
Active Threads : 2
Thread 3 is running.
Active Threads : 3
Active Threads : 3
Active Threads : 3
Active Threads : 3
Thread 1 is running again.
Thread 2 is running again.
Thread 3 is running again.
Active Threads : 1
Active Threads : 0

© 著作权归作者所有

共有 人打赏支持
z
粉丝 2
博文 4
码字总数 2818
作品 0
济南
私信 提问
Spring Boot 最核心的 3 个注解详解

最近面试一些 Java 开发者,他们其中有些在公司实际用过 Spring Boot, 有些是自己兴趣爱好在业余自己学习过。然而,当我问他们 Spring Boot 最核心的 3 个注解是什么,令我失望的是鲜有人能答...

Java技术栈
2018/10/16
0
0
新书上架:《Spring Boot 开发实战》(基于 Kotlin + Gradle + Spring Boot 2.0 的企业级服务端开发实战)

新书上架:《Spring Boot 开发实战》 — 基于 Kotlin + Gradle + Spring Boot 2.0 的企业级服务端开发实战 京东下单链接 https://item.jd.com/31178320122.html 天猫下单链接 https://detail...

程序员诗人
2018/08/05
0
0
Spring IOC知识点一网打尽!

前言 只有光头才能变强 回顾前面: 给女朋友讲解什么是代理模式 包装模式就是这么简单啦 单例模式你会几种写法? 工厂模式理解了没有? 在刷Spring书籍的时候花了点时间去学习了单例模式和工...

Java3y
2018/05/22
0
0
新书上架:《Spring Boot 开发实战》基于 Kotlin + Gradle + Spring Boot 2.0 的企业级服务端开发实战

新书上架:《Spring Boot 开发实战》 — 基于 Kotlin + Gradle + Spring Boot 2.0 的企业级服务端开发实战 京东下单链接 https://item.jd.com/31178320122.html 天猫下单链接 https://detail...

程序员诗人
2018/08/22
0
0
自定义spring boot starter三部曲之三:源码分析spring.factories加载过程

版权声明:欢迎转载,请注明出处,谢谢。 https://blog.csdn.net/boling_cavalry/article/details/83048588 本文是《自定义spring boot starter三部曲》系列的终篇,前文中我们开发了一个sta...

博陵精骑
2018/10/20
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Java12的新特性

Java语言特性系列 Java5的新特性 Java6的新特性 Java7的新特性 Java8的新特性 Java9的新特性 Java10的新特性 Java11的新特性 Java12的新特性 Java13的新特性 序 本文主要讲述一下Java12的新特...

go4it
13分钟前
1
0
深入解密比Guava Cache更优秀的缓存-Caffeine

1.前言 读这篇文章之前希望你能好好的阅读: 你应该知道的缓存进化史 和 如何优雅的设计和使用缓存? 。这两篇文章主要从一些实战上面去介绍如何去使用缓存。在这两篇文章中我都比较推荐Caffe...

咖啡拿铁的技术分享
15分钟前
1
0
Java B2B2C多用户商城 springcloud架构 --Eureka服务器搭建及配置

第一步,创建一个普通的springboot项目 以下方法都可以快速创建一个boot项目: 1. 浏览器访问http://start.spring.io/,填写信息,下载zip包,加压到你的ide的工作空间直接使用。 2. 使用ide...

明理萝
26分钟前
0
1
为什么阿里巴巴禁止在 foreach 循环里进行元素的 remove/add 操作

· Oracle 撒手,宣布对个人用户 (Personal Users) , Java 8 官方支持时间持续到 2020 年 12 月;对商业用户(Commercial Users),2019 年 1 月之后不再提供免费更新。 · 红帽喊话,计划在...

Java填坑路
29分钟前
0
0
在 Ali Kubernetes 系统中,我们这样实践混沌工程

在传统的软件测试中,我们通常通过一个给定的条件来判断系统的反馈,通过断言来判断是否符合预期,测试条件和结果通常比较明确和固定。而混沌工程,是通过注入一些“不确定”因素,象放进了一...

阿里云官方博客
30分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部