详解spring多线程与定时任务

2024-07-13 10:06:20

字体：大中小

来源：转载

供稿：网友

本篇主要描述一下spring的多线程的使用与定时任务的使用.

1.spring多线程任务的使用

spring通过任务执行器TaskExecutor来实现多线程与并发编程。通常使用ThreadPoolTaskExecutor来实现一个基于线程池的TaskExecutor.

首先你要实现AsyncConfigurer 这个接口，目的是开启一个线程池

代码如下:

package com.foreveross.service.weixin.test.thread;import java.util.concurrent.Executor;import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;import org.springframework.context.annotation.ComponentScan;import org.springframework.context.annotation.Configuration;import org.springframework.scheduling.annotation.AsyncConfigurer;import org.springframework.scheduling.annotation.EnableAsync;import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;/** * 注入一个线程池 * @author mingge * */@Configuration@ComponentScan("com.foreveross.service.weixin.test.thread")@EnableAsyncpublic class TaskExecutorConfig implements AsyncConfigurer {  @Override  public Executor getAsyncExecutor() {    ThreadPoolTaskExecutor taskExecutor=new ThreadPoolTaskExecutor();    taskExecutor.setCorePoolSize(5);    taskExecutor.setMaxPoolSize(20);    taskExecutor.setQueueCapacity(25);    taskExecutor.initialize();    return taskExecutor;  }  @Override  public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {    return null;  }  }

然后注入一个类，实现你的业务，并在你的Bean的方法中使用@Async注解来声明其是一个异步任务

代码如下:

package com.foreveross.service.weixin.test.thread;import org.springframework.scheduling.annotation.Async;import org.springframework.stereotype.Service;/** * 线程池任务 * @author mingge * */@Servicepublic class TaskService {  @Async  public void executeAsyncTask(int i){    System.out.println("执行异步任务:"+i);  }    @Async  public void executeAsyncTask1(int i){    System.out.println("执行异步任务1:"+(i+i));  }}

最后通过测试，可以看到你的实现是异步执行了.

package com.foreveross.service.weixin.test.thread;import org.springframework.context.annotation.AnnotationConfigApplicationContext;/** *  * @author mingge * */public class Test {  public static void main(String[] args) {    AnnotationConfigApplicationContext context=new AnnotationConfigApplicationContext(TaskExecutorConfig.class);    TaskService taskService=context.getBean(TaskService.class);    for(int i=0;i<20;i++){      taskService.executeAsyncTask(i);      taskService.executeAsyncTask1(i);    }    //最后可以根据结果可以看出结果是并发执行而不是顺序执行的呢    context.close();  }}

2.spring定时任务的使用

在java原生态中，我们使用timer就可以了，这里小编说一些在Spring中的定时任务的使用

package com.foreveross.service.weixin.test.thread;import org.springframework.context.annotation.ComponentScan;import org.springframework.context.annotation.Configuration;import org.springframework.scheduling.annotation.EnableScheduling;@Configuration@ComponentScan("com.foreveross.service.weixin.test.thread")@EnableScheduling//开启对定时器的支持public class TaskSchedulerConfig {}

package com.foreveross.service.weixin.test.thread;import java.util.Date;import org.springframework.scheduling.annotation.Scheduled;import org.springframework.stereotype.Service;@Servicepublic class TimerTaskJob {  @Scheduled(fixedRate=2000)  public void test(){    System.out.println("我是定时任务:"+new Date().getSeconds());  }}

package com.foreveross.service.weixin.test.thread;import org.springframework.context.annotation.AnnotationConfigApplicationContext;public class TestTimer {  public static void main(String[] args) {    AnnotationConfigApplicationContext context=new AnnotationConfigApplicationContext(TaskSchedulerConfig.class);        //context.close();  }}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持VeVb武林网。

注：相关教程知识阅读请移步到JAVA教程频道。

上一篇：spring boot配合前端实现跨域请求访问

下一篇：SpringMVC中解决@ResponseBody注解返回中文乱码问题