进口外贸流程,无锡seo公司网站,全栈网站开发者,公司名字变了网站备案Springboot对多线程的支持详解这两天看阿里的JAVA开发手册#xff0c;到多线程的时候说永远不要用 new Thread()这种方式来使用多线程。确实是这样的#xff0c;我一直在用线程池#xff0c;到了springboot才发现他已经给我们提供了很方便的线程池机制。本博客代码托管在git…Springboot对多线程的支持详解这两天看阿里的JAVA开发手册到多线程的时候说永远不要用 new Thread()这种方式来使用多线程。确实是这样的我一直在用线程池到了springboot才发现他已经给我们提供了很方便的线程池机制。本博客代码托管在github上https://github.com/gxz0422042...一、介绍Spring是通过任务执行器(TaskExecutor)来实现多线程和并发编程使用ThreadPoolTaskExecutor来创建一个基于线城池的TaskExecutor。在使用线程池的大多数情况下都是异步非阻塞的。我们配置注解EnableAsync可以开启异步任务。然后在实际执行的方法上配置注解Async上声明是异步任务。二、配置类配置类代码如下package com.spartajet.springbootlearn.thread;import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;import org.springframework.context.annotation.Configuration;import org.springframework.scheduling.annotation.AsyncConfigurer;import org.springframework.scheduling.annotation.EnableAsync;import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;import java.util.concurrent.Executor;/*** description* create 2017-02-22 下午11:53* email gxz04220427163.com*/ConfigurationEnableAsyncpublic class ThreadConfig implements AsyncConfigurer {/*** The {link Executor} instance to be used when processing async* method invocations.*/Overridepublic Executor getAsyncExecutor() {ThreadPoolTaskExecutor executor new ThreadPoolTaskExecutor();executor.setCorePoolSize(5);executor.setMaxPoolSize(15);executor.setQueueCapacity(25);executor.initialize();return executor;}/*** The {link AsyncUncaughtExceptionHandler} instance to be used* when an exception is thrown during an asynchronous method execution* with {code void} return type.*/Overridepublic AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {return null;}}解读利用EnableAsync来开启Springboot对于异步任务的支持配置类实现接口AsyncConfigurator返回一个ThreadPoolTaskExecutor线程池对象。三、任务执行任务执行代码package com.spartajet.springbootlearn.thread;import org.springframework.scheduling.annotation.Async;import org.springframework.stereotype.Service;/*** description* create 2017-02-23 上午12:00* email gxz04220427163.com*/Servicepublic class AsyncTaskService {Asyncpublic void executeAsyncTask(int i) {System.out.println(线程 Thread.currentThread().getName() 执行异步任务 i);}}代码解读通过Async注解表明该方法是异步方法如果注解在类上那表明这个类里面的所有方法都是异步的。四、测试代码package com.spartajet.springbootlearn;import com.spartajet.springbootlearn.thread.AsyncTaskService;import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import org.springframework.test.context.junit4.SpringRunner;RunWith (SpringRunner.class)SpringBootTestpublic class SpringbootLearnApplicationTests {Autowiredprivate AsyncTaskService asyncTaskService;Testpublic void contextLoads() {}Testpublic void threadTest() {for (int i 0; i 20; i) {asyncTaskService.executeAsyncTask(i);}}}测试结果线程ThreadPoolTaskExecutor-4 执行异步任务3线程ThreadPoolTaskExecutor-2 执行异步任务1线程ThreadPoolTaskExecutor-1 执行异步任务0线程ThreadPoolTaskExecutor-1 执行异步任务7线程ThreadPoolTaskExecutor-1 执行异步任务8线程ThreadPoolTaskExecutor-1 执行异步任务9线程ThreadPoolTaskExecutor-1 执行异步任务10线程ThreadPoolTaskExecutor-5 执行异步任务4线程ThreadPoolTaskExecutor-3 执行异步任务2线程ThreadPoolTaskExecutor-5 执行异步任务12线程ThreadPoolTaskExecutor-1 执行异步任务11线程ThreadPoolTaskExecutor-2 执行异步任务6线程ThreadPoolTaskExecutor-4 执行异步任务5线程ThreadPoolTaskExecutor-2 执行异步任务16线程ThreadPoolTaskExecutor-1 执行异步任务15线程ThreadPoolTaskExecutor-5 执行异步任务14线程ThreadPoolTaskExecutor-3 执行异步任务13线程ThreadPoolTaskExecutor-1 执行异步任务19线程ThreadPoolTaskExecutor-2 执行异步任务18线程ThreadPoolTaskExecutor-4 执行异步任务17
