ListenableFuture异步支持
Service Keeper
内置了用于处理返回值为ListenableFuture
的异步处理器ListenableFutureHandler
,使用时首先需要引入依赖:
<dependency>
<groupId>io.esastack</groupId>
<artifactId>servicekeeper-ext-listenablefuture</artifactId>
<version>${servicekeeper.version}</version>
</dependency>
如果是Spring环境则直接将该Handler注入Bean容器,如:
@Bean
public listenableFutureHandler listenableFutureHandler() {
return new ListenableFutureHandler();
}
Note
由于Restlight
默认支持ListenableFuture
,因此servicekeeper-restlight-adapter
模块中默认注入了ListenableFutureHandler
。
对于非Spring容器,可在初始化时传入该Handler的实例,如:
ServiceKeeperInvoker.init(Collections.singletonList(new ListenableFutureHandler<>()));