Java实现Promise.all()的示例代码 - 第一PHP社区

安宇雨 - 随手采集
2022-10-21 23:01:05
随手采集
0000-未整理-等待研究

当前位置: 开发笔记 > 编程语言 > 正文

Java实现Promise.all()的示例代码

作者：刘家大宝688 | 来源：互联网 | 2021-09-13 07:22

这篇文章主要介绍了Java实现Promise.all()的示例代码，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧

Javascript的Promise.all()

Promise是Javascript异步编程的一种解决方案，在ES6中引入。

通过Promise.all()可以实现对一组异步请求的统一处理，等待所有异步执行完成之后调用回调函数。

其实，这种并发执行同步等待的需求在Java并发编程中也很常见，那么，是否可以通过Java也来实现这样一个Promise类呢？

使用Java实现Promise.all()

使用工具

CountDownLatch：Java并发工具包中有CountDownLatch类允许一个或多个线程等待其他线程的一系列操作完成。

ThreadPoolExecutor：通过线程池实现多线程的并发执行

实现

public class Promise {

private static ExecutorService executorService = Executors.newScheduledThreadPool(`16`);

private Promise() {

throw new AssertionError();

}

/**

* 实现并发同时地对某个action并发执行并返回执行结果

* 实现思路：

* 并发创建所有执行的线程，并通过锁(start)阻塞等待着

* 在创建所有执行的线程后(ready)开始计时，并解锁然所有的线程启动

* 通过另外一个锁（done）记录执行完的线程

* 主线程只需关心3点

* - 所有线程是否准备好

* - 准备好的话开始计时并解锁开始执行

* - 等待执行完毕

*

* @param callableList 要并发执行的列表

* @return list 执行结果，list.item为null的话表示执行异常

* @throws InterruptedException 异常

*/

public static

List all(final List> callableList) throws InterruptedException { final List result = new ArrayList<>(); int length = callableList.size(); final CountDownLatch ready = new CountDownLatch(length); final CountDownLatch start = new CountDownLatch(1); final CountDownLatch dOne= new CountDownLatch(length); for (final Callable callable : callableList) { executorService.execute(new Runnable() { @Override public void run() { ready.countDown(); try { start.await(); T t = callable.call(); result.add(t); } catch (Exception e) { // interrupt when exception Thread.currentThread().interrupt(); // set null mean exception result.add(null); e.printStackTrace(); } finally { done.countDown(); } } }); } ready.await(); long startnano = System.nanoTime(); start.countDown(); done.await(); long cause = System.nanoTime() - startnano; System.out.println(String.format("Promise all done,cause time millSecond: %s", cause / 1000000)); return result; } }

效果

测试

public void promiseAllTest() throws Exception{

List<callable<string>> callables = new ArrayList<>();

for (`int i = 0; i <10`; i++) {

int finalI = i;

callables.add(`new Callable<string>() {`

@Override

public String call() throws Exception {

int millis = new Random().nextInt(`10000`);

Thread.sleep(millis);

System.out.println(String.format(`"thread%s sleep %s millis" ,finalI,millis));`

return "Thread" + finalI;

}

});

}

List<string> result = Promise.all(callables);

System.out.println(result);

System.out.println(`"done..."`);

}

</string></string></callable<string>

测试结果

thread1 sleep 732 millis
thread2 sleep 758 millis
thread7 sleep 976 millis
thread8 sleep 1397 millis
thread5 sleep 1513 millis
thread0 sleep 2221 millis
thread3 sleep 4885 millis
thread6 sleep 5221 millis
thread4 sleep 7101 millis
thread9 sleep 7634 millis
Promise all done,cause time millSecond: 7638
[Thread1, Thread2, Thread7, Thread8, Thread5, Thread0, Thread3, Thread6, Thread4, Thread9]
done...

总结

本文只是通过原生Java实现简单版本的Promise.all()，可用于简单的并发编程，但是对于实际高并发应用还需要优化，如对线程池的优化,还有中断的处理等。

参考

《Effective Java》第二版第十章第69条：并发工具优先于wait和notify

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

原网址: 访问
创建于: 2022-10-21 23:01:04
目录: default
标签: 无

未标明原创文章均为采集，版权归作者所有，转载无需和我联系，请注明原出处，南摩阿彌陀佛，知识，不只知道，要得到