β

Java8 基于spring @Async方法和Lambda实现任意代码块异步执行

Harries Blog™ 100 阅读

使用jdk8有一段 时间 了,经常到 stream lambda 操作集合,项目一般也都使用的是 spring framework系列。借助lambda可以实现类似 python 闭包的写法,传递 代码 块给方法,异步方法加让lambda就可以实现任意代码块的异步执行。

首先定一个接口用来执行异步代码块

public interface AsyncService {

    void asyncInvoke(AsyncExec consumer) throws WxErrorException;

    @FunctionalInterface
    interface AsyncExec {
        void exec() throws WxErrorException;
    }
}

给一个实现并交给spring容器 管理

@Service
public class AsyncServiceImpl implements AsyncService {

    @Async
    @Override
    public void asyncInvoke(AsyncExec asyncExec) throws WxErrorException {
        asyncExec.exec();
    }
}

简单 测试 一下

@RunWith(SpringRunner.class)
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
@ActiveProfiles("dev")
@Slf4j
public class AsyncServiceTest {

    @Autowired
    private AsyncService asyncService;

    @Test
    public void asyncServiceTest() throws WxErrorException,   InterruptedException {
        log.info("111111111111111");
        asyncService.asyncInvoke(() -> {
            try {
                Thread.sleep(1000);
                log.info("异步方法执行");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });
        log.info("222222222222222");
        Thread.sleep(2000);
    }
}

测试结果

Java8 基于spring @Async方法和Lambda实现任意代码块异步执行

原文

https ://www.jgayb.cn/?p=140

本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。 PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处: Harries Blog™ » Java8 基于spring @Async方法和Lambda实现任意代码块异步执行

作者:Harries Blog™
追心中的海,逐世界的梦

发表评论