X

你应该这样去开发接口:Java多线程并行计算

所谓的高并发除了在架构上的高屋建瓴,还得需要开发人员在具体业务开发中注重自己的每一行代码、每一个细节,面子有的同时,更重要的还是要有里子。

可以看到我这里调用了4个方法,每一个方法为模拟真实耗时,所以都是延迟100ms返回一个字符串:

线程池+Future

多运行几次,看输出响应时间:

耗时:108ms
耗时:105ms
耗时:105ms

效果是不是很明显?

直接相当于一个方法的调用耗时,实际开发中如果你的一个接口经过压测耗时在100ms左右(大多数正规公司对接口性能都会要求不超过100ms),那么再通过线程池+Future并行计算的方式,并可以瞬间将你的接口性能提高上去,再也不用担心压测不过了。

有时候测试同学告诉你接口压测不过是不是觉得很没面子?那是对你职业水平最大的否定~

Java8的CompletableFuture

Future是java.util.concurrent并发包中的接口类,用来表示一个线程异步执行后的结果,有如下核心方法:

  • Future.get():阻塞调用线程,直到计算结果返回
  • Future.isDone():判断线程是否执行完毕
  • Future.cancel():取消当前线程的执行

我们可以知道的是,Future.get()是阻塞调用的,要想拿到线程执行的结果,必须是Future.get()阻塞或者while(Future.isDone())轮询方式调用。这种方式叫“主动拉(pull)”,现在都流行响应式编程,即“主动推(push)”的方式,当线程执行完了,你告诉我就好了。

Java8设计了CompletableFuture这样的一个类,我们先来看看如何用CompletableFuture来开发之前的代码:

执行三次请求耗时:

耗时:103ms
耗时:101ms
耗时:103ms最后

以上就是如何让自己的接口并行计算起来的三种实现方式,属于日常开发中比较常用的一个小技巧,这里没有过多说明这三种方式的具体区别,实际上还需要大家不断的在开发中去使用,查阅更多相关源码和资料,只有等你真正用起来的时候,你才能有所体会!

感谢各位的阅读,如果这篇文章对您有帮助,欢迎“点赞+转发”!关注“java架构设计”获取更多免费技术文章干货!