Spring Boot中开启异步任务,并使用回调函数处理异步任务的结果
创始人
2025-05-31 11:47:27

一、在spring boot中使用Async,来实现异步任务

在Spring Boot中,可以使用@Autowired注解将一个类的实例注入到另一个类中,并使用@Async注解来开启一个新的线程来运行该类的方法。下面是一个简单的示例:

1、添加Async的配置文件

在使用@Async注解之前,需要在Spring Boot的配置文件中开启异步支持:

spring:task:execution:pool:core-size: 10max-size: 20

上面的配置会创建一个大小为10的线程池,最大线程数为20。这样,当我们调用doSomething方法时,它会在一个新的线程中执行。

在启动类中添加启用异步任务的注解
@EnableAsync

2、创建异步任务

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;@Component
public class MyService {@Asyncpublic void doSomething(String param) {// 在新线程中执行的代码System.out.println("Received parameter: " + param);}
}

在上面的示例中,MyService类的doSomething()方法使用了@Async注解,表明该方法将在一个新的线程中执行。该方法接收一个字符串参数,并在新线程中输出该参数的值。

3、调用异步任务

现在,假设有另一个类需要传递参数给MyService类,并开启一个新的线程来执行doSomething()方法。可以在该类中使用@Autowired注解来注入MyService类的实例,并直接调用doSomething()方法,如下所示:

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;@Component
public class AnotherClass {@Autowiredprivate MyService myService;public void runInNewThread(String param) {new Thread(() -> {myService.doSomething(param);}).start();}
}

在上面的示例中,AnotherClass类中的runInNewThread()方法接收一个字符串参数,并在新线程中调用MyService类的doSomething()方法,将该参数传递给它。要注意的是,AnotherClass类需要使用@Component注解标记为一个Spring组件,以便Spring容器可以扫描和管理它。

二、使用回调函数,处理异步任务的结果

使用异步编程有一个问题,就是异步操作完成后,如何处理它的结果呢?这时候可以使用回调函数来处理异步结果。

在Spring Boot中,可以使用CompletableFuture来处理异步结果。CompletableFuture是一个异步编程的工具类,可以让我们更方便地处理异步结果。

下面是一个使用CompletableFuture来处理异步结果的例子:

@Service
public class SomeService {@Asyncpublic CompletableFuture longRunningMethod() {// 耗时操作int result = 100;return CompletableFuture.completedFuture(result);}}@Service
public class AnotherService {@Autowiredprivate SomeService someService;public void doSomething() {CompletableFuture future = someService.longRunningMethod();future.thenAccept(result -> {// 处理异步结果System.out.println("异步结果:" + result);});}}

上面的代码中,longRunningMethod方法返回一个CompletableFuture对象,表示异步结果。在doSomething方法中,我们调用longRunningMethod方法,并使用thenAccept方法注册一个回调函数,当异步结果完成后,回调函数会被执行。

回调函数的参数result表示异步结果,我们可以在回调函数中对结果进行处理,比如输出结果到控制台。

相关内容

热门资讯

魏建军回应“九年八换CEO”:... 出品丨虎嗅汽车组作者丨魏微头图丨长城汽车“有人说我们(魏牌)换了不少的CEO了,的的确确是这么回事,...
东方雨虹子公司疑遭电诈被骗逾千... 12月23日晚,东方雨虹公告,公司近日获悉,公司下属美国全资子公司OYH建材公司疑遭电信诈骗,涉案金...
造孽,挖了个大大坑 图: Antоn Gudim 年底了。 我一个女朋友给我晒她的账户,她买了几个ETF,基本都持有3-...
21天翻倍!溢价近60%,白银... 白银的火热,正以一种近乎疯狂的方式在二级市场上演。12月23日,国投白银LOF再度斩获涨停,实现两连...
快手不是我朋友 马上就要元旦了,那一天不但有元旦,还有新修订的《中华人民共和国治安管理处罚法》。那里面不但有前一段热...