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

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

public interface AsyncService {

    void asyncInvoke(AsyncExec consumer);

    void asyncInvokeStream(AsyncExec... asyncExecs);

    void asyncInvokeParallelStream(AsyncExec... asyncExecs);

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

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

@Service
public class AsyncServiceImpl implements AsyncService {
    /**
     * 单任务异步执行
     *
     * @param consumer 执行器
     */
    @Override
    @Async
    public void asyncInvoke(@NonNull AsyncExec consumer) {
        consumer.exec();
    }


    /**
     * 多个异步任务顺序执行
     *
     * @param asyncExecs 多个执行器
     */
    @Override
    @Async
    public void asyncInvokeStream(AsyncExec... asyncExecs) {
        Arrays
                .stream(asyncExecs)
                .forEach(AsyncExec::exec);
    }

    /**
     * 多个异步任务并行执行
     *
     * @param asyncExecs 多个执行器
     */
    @Override
    @Async
    public void asyncInvokeParallelStream(AsyncExec... asyncExecs) {
        Arrays
                .stream(asyncExecs).parallel()
                .forEach(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);
    }
}

测试结果

单元测试截图

1 对 “Java8 基于spring @Async方法和Lambda实现任意代码块异步执行”的想法;

发表评论

电子邮件地址不会被公开。 必填项已用*标注