spring框架管理线程池

蔚落 2021-06-10 20:42 393阅读 0赞

今天来记录一下，如何通过  spring框架 简单配置并管理 线程池

1、首先需要搭建好一个简单的spring框架（当然知道是屁话）

如果不知道怎么搭建spring框架的同学可以看我的上一篇文章，也有可能是上上一篇文章（总之自己找吧）。

2、在applicationContext.xml中配置线程池，如下图：

![Center][]

代码需要码在beans标签内，代码如下：

<bean id="threadPool" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">  <property name="corePoolSize" value="2">  <property name="maxPoolSize" value="3">  <property name="queueCapacity" value="10">  <property name="keepAliveSeconds" value="300">  <property name="rejectedExecutionHandler"> <bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy"> </bean></property> </property></property></property></property></bean> <bean id="taskUtil" class="spring.taskutil.ThreadTask">  <property name="taskExecutor" ref="threadPool"> </property></bean>

3、新建上述代码中的 spring.taskutil.ThreadTask类（包名+类型的形式），如下图：

![Center 1][]

图中代码如下：

private TaskExecutor taskExecutor; public TaskExecutor getTaskExecutor() \{ return taskExecutor; \} public void setTaskExecutor(TaskExecutor taskExecutor) \{ this.taskExecutor = taskExecutor; \} public void printMessages(Runnable r,int i) \{ taskExecutor.execute(r); System.out.println("add Thread："+i); \}

4、新建启动的线程类：

![Center 2][]

图中代码如下：

private String message; public MyThread() \{ \} public MyThread(String message) \{ this.message = message; \} public void run() \{ try \{ Thread.sleep(5000); \} catch (InterruptedException e) \{ // TODO Auto-generated catch block e.printStackTrace(); \} System.out.println(message); \}

5、新建测试类：

![Center 3][]

这里面的代码就不给大家了，代码码完后，run as--> java application 就可以看到结果了

如果又不对的地方，还请大神及时指出，以免误人子弟

[Center]: /images/20210522/f5f32e2076344ec88b0d2d3309677048.png
[Center 1]: /images/20210522/2f98c0524e5a4c2bbbb2804adf7b18f1.png
[Center 2]: /images/20210522/32c0bcb77e7c45de9086c796b39f1133.png
[Center 3]: /images/20210522/d557c944b1d74267b7fdcf1e27726978.png