当前位置: 首页 > news >正文

Java 实现 Awaitable(多线程并行等待,类似 AutoEventReset 的作用)

 AutoEventReset、ManualEventReset,是我们在多线程并行编程之中常常需要涉及的,但是 ManualEventReset 可能用的并没有那么多,这个多用于实现读写锁的,当然 Java 自己库提供了官方实现,就没必要自己去整了。

C/C++ 里面的话,这块基本都是自己写的,毕竟标准库STL得功能咋个说,这块太弱了,说没也有点东西,说有东西又差了很多点的意思,得自己上马搞底层造轮子,总之奇奇怪怪。

 java 这里面得话,官方提供了 CountDownLatch 类可以模拟实现这个效果,但是呢必须封装一下,否则不太好用,就跟 C/C++1xx 之中得 std::condition_variable 不封装下,用起来不太顺手。

Awaitable 直接说,就两核心接口:

1、await(那个线程要等待其它线程任务结束就执行这个)

2、 processed (其它处理任务得线程完成了调用这个,顾名思义:处理结束)

这种需求很正常得,并非所有情况都适用协程或FULL ASYNC得情况,至于协程JAVA得额滴不太懂,本人就一JAVA,N多年没在摸过得划水半吊子,只是近期整下安卓APP开源解决方案需要重新涉及下JAVA语言整整软件底层实现,仅此而已。

例子:

        Awaitable awaitable = new Awaitable();new Thread(() -> {System.out.println("B\n");awaitable.processed();}).start();awaitable.await();System.out.println("A\n");

源实现:

public class Awaitable {private final AtomicReference<Event> event_ = new AtomicReference<>();private Object tag_ = null;private static class Event {private final CountDownLatch lk_ = new CountDownLatch(1);public boolean processed() {try {lk_.countDown();return true;} catch (Throwable ignored) {return false;}}public boolean await() {try {lk_.await();return true;} catch (Throwable ignored) {return false;}}}public void tag(Object v) {this.tag_ = v;}public Object tag() {return this.tag_;}// B Thread call.public boolean processed() {Event event = this.event_.getAndSet(null);if (event == null) {return false;}return event.processed();}// A Thread call.public boolean await() {Event event = new Event();if (this.event_.compareAndSet(null, event)) {return event.await();}return false;}
}

http://www.lryc.cn/news/303427.html

相关文章:

  • AI之Sora:Sora(文本指令生成视频的里程碑模型)的简介(能力/安全性/技术细节)、使用方法、案例应用之详细攻略
  • IListManger feeds流
  • 视频推拉流EasyDSS视频直播点播平台授权出现激活码无效并报错400是什么原因?
  • 设计模式三:工厂模式
  • 2024.2.15 模拟实现 RabbitMQ —— 消息持久化
  • 【技巧】金融企业在搭建服务器时,选择私有云方案还是全栈专属云?
  • 【大厂AI课学习笔记】【2.2机器学习开发任务实例】(10)模型评测
  • 【C++游戏开发-03】贪吃蛇
  • 如何理解CSS的边框宽度?
  • java 写入写出 zip
  • 问题解决:‘telnet‘ 不是内部或外部命令,也不是可运行的程序 或批处理文件
  • 从基础到高级:Linux用户与用户组权限设置详解
  • 【感知机】感知机(perceptron)学习算法知识点汇总
  • 蓝桥杯:C++二分算法
  • Leetcode刷题笔记题解(C++):83. 删除排序链表中的重复元素
  • @ 代码随想录算法训练营第8周(C语言)|Day56(动态规划)
  • C# OpenCvSharp DNN Image Retouching
  • 通过Docker Compose的方式在Docker中安装Maven环境
  • Python实现线性逻辑回归和非线性逻辑回归
  • 【软考】软件维护
  • 突破性创新:OpenAI推出Sora视频模型,预示视频制作技术的未来已到来!
  • 【Web前端笔记10】CSS3新特性
  • LabVIEW荧光显微镜下微管运动仿真系统开发
  • 【Java面试】MQ(Message Queue)消息队列
  • 【安卓基础1】初识Android
  • 08-静态pod(了解即可,不重要)
  • PROBIS铂思金融破产后续:ASIC牌照已注销
  • 数字世界的探索者:计算机相关专业电影精选推荐
  • Spring Boot项目中TaskDecorator的应用实践
  • 511. 游戏玩法分析 I