前言线程间通信是并发编程的基础能力HarmonyOS提供了Emitter机制用于线程间事件传递。pura/harmony-utils的EmitterUtil封装了Emitter的订阅和发送方法简化了线程间通信的实现。本文将从API说明、代码实战、进阶用法、常见问题等多个维度进行全面讲解帮助开发者快速掌握并应用到实际项目中。一、EmitterUtil核心APIEmitterUtil提供了以下线程间通信方法方法说明参数使用场景on(eventId, callback)订阅事件eventId, callback事件监听off(eventId, callback)取消订阅eventId, callback释放资源emit(eventId, data)发送事件eventId, data事件触发1.1 核心特性简洁易用封装复杂API为一行调用降低使用门槛类型安全完整的TypeScript类型定义编译期即可发现错误异常处理内置异常捕获机制避免运行时崩溃线程安全支持跨线程事件传递1.2 事件ID管理建议范围说明示例1000-1999用户交互事件点击、长按2000-2999数据更新事件数据刷新、同步3000-3999系统状态事件网络变化、电量变化二、完整使用步骤2.1 安装依赖ohpminstallpura/harmony-utils2.2 订阅事件import{EmitterUtil}frompura/harmony-utils;privateeventCallback(data){this.result收到事件:${JSON.stringify(data)};};aboutToAppear(){EmitterUtil.on(1001,this.eventCallback);}aboutToDisappear(){EmitterUtil.off(1001,this.eventCallback);}2.3 发送事件Button(发送事件).width(100%).onClick((){try{EmitterUtil.emit(1001,{message:Hello from Emitter!});this.result事件已发送 ;}catch(e){this.result异常: e;}})三、完整页面示例import{EmitterUtil}frompura/harmony-utils;EntryComponentstruct EmitterDemo{Stateresult:string;aboutToAppear(){EmitterUtil.on(1001,(data){this.result收到:${JSON.stringify(data)};});}aboutToDisappear(){EmitterUtil.off(1001);}build(){Column({space:12}){Button(发送事件).width(100%).onClick((){EmitterUtil.emit(1001,{msg:Hello});});Text(this.result).fontSize(14).fontColor(#333333)}.padding(16)}}四、进阶用法4.1 事件总线import{EmitterUtil}frompura/harmony-utils;classEventBus{staticreadonlyEVENTS{USER_LOGIN:1001,DATA_REFRESH:2001,NETWORK_CHANGE:3001};staticon(eventId:number,callback:Function):void{EmitterUtil.on(eventId,callback);}staticemit(eventId:number,data?:Object):void{EmitterUtil.emit(eventId,data);}staticoff(eventId:number,callback?:Function):void{EmitterUtil.off(eventId,callback);}}4.2 跨组件通信EmitterUtil.emit(2001,{action:refresh,target:userList});五、注意事项事件ID建议使用常量定义事件ID避免硬编码取消订阅页面销毁时务必取消订阅避免内存泄漏回调引用订阅和取消需使用同一回调引用初始化依赖使用前需确保AppUtil.init()已调用事件数据事件数据应尽量精简避免传递大对象六、常见问题Q1: 事件发送后回调不触发检查事件ID是否一致回调是否正确注册。Q2: 多次订阅同一事件会触发多次吗是的每个订阅的回调都会触发注意避免重复订阅。Q3: 可以跨Ability通信吗EmitterUtil支持同进程内的线程间通信跨进程需使用其他方案。Q4: 事件数据大小有限制吗建议事件数据不超过10KB大数据建议通过文件或数据库传递。总结EmitterUtil的线程间通信方法为组件间和线程间的事件传递提供了便捷支持。本文详细介绍了核心API、使用步骤、完整示例、进阶用法以及常见问题的解决方案。开发者可以利用事件总线模式实现松耦合的组件通信。本文基于pura/harmony-utils工具库更多功能请参考官方文档与后续系列文章。
前言线程间通信是并发编程的基础能力HarmonyOS提供了Emitter机制用于线程间事件传递。pura/harmony-utils的EmitterUtil封装了Emitter的订阅和发送方法简化了线程间通信的实现。本文将从API说明、代码实战、进阶用法、常见问题等多个维度进行全面讲解帮助开发者快速掌握并应用到实际项目中。一、EmitterUtil核心APIEmitterUtil提供了以下线程间通信方法方法说明参数使用场景on(eventId, callback)订阅事件eventId, callback事件监听off(eventId, callback)取消订阅eventId, callback释放资源emit(eventId, data)发送事件eventId, data事件触发1.1 核心特性简洁易用封装复杂API为一行调用降低使用门槛类型安全完整的TypeScript类型定义编译期即可发现错误异常处理内置异常捕获机制避免运行时崩溃线程安全支持跨线程事件传递1.2 事件ID管理建议范围说明示例1000-1999用户交互事件点击、长按2000-2999数据更新事件数据刷新、同步3000-3999系统状态事件网络变化、电量变化二、完整使用步骤2.1 安装依赖ohpminstallpura/harmony-utils2.2 订阅事件import{EmitterUtil}frompura/harmony-utils;privateeventCallback(data){this.result收到事件:${JSON.stringify(data)};};aboutToAppear(){EmitterUtil.on(1001,this.eventCallback);}aboutToDisappear(){EmitterUtil.off(1001,this.eventCallback);}2.3 发送事件Button(发送事件).width(100%).onClick((){try{EmitterUtil.emit(1001,{message:Hello from Emitter!});this.result事件已发送 ;}catch(e){this.result异常: e;}})三、完整页面示例import{EmitterUtil}frompura/harmony-utils;EntryComponentstruct EmitterDemo{Stateresult:string;aboutToAppear(){EmitterUtil.on(1001,(data){this.result收到:${JSON.stringify(data)};});}aboutToDisappear(){EmitterUtil.off(1001);}build(){Column({space:12}){Button(发送事件).width(100%).onClick((){EmitterUtil.emit(1001,{msg:Hello});});Text(this.result).fontSize(14).fontColor(#333333)}.padding(16)}}四、进阶用法4.1 事件总线import{EmitterUtil}frompura/harmony-utils;classEventBus{staticreadonlyEVENTS{USER_LOGIN:1001,DATA_REFRESH:2001,NETWORK_CHANGE:3001};staticon(eventId:number,callback:Function):void{EmitterUtil.on(eventId,callback);}staticemit(eventId:number,data?:Object):void{EmitterUtil.emit(eventId,data);}staticoff(eventId:number,callback?:Function):void{EmitterUtil.off(eventId,callback);}}4.2 跨组件通信EmitterUtil.emit(2001,{action:refresh,target:userList});五、注意事项事件ID建议使用常量定义事件ID避免硬编码取消订阅页面销毁时务必取消订阅避免内存泄漏回调引用订阅和取消需使用同一回调引用初始化依赖使用前需确保AppUtil.init()已调用事件数据事件数据应尽量精简避免传递大对象六、常见问题Q1: 事件发送后回调不触发检查事件ID是否一致回调是否正确注册。Q2: 多次订阅同一事件会触发多次吗是的每个订阅的回调都会触发注意避免重复订阅。Q3: 可以跨Ability通信吗EmitterUtil支持同进程内的线程间通信跨进程需使用其他方案。Q4: 事件数据大小有限制吗建议事件数据不超过10KB大数据建议通过文件或数据库传递。总结EmitterUtil的线程间通信方法为组件间和线程间的事件传递提供了便捷支持。本文详细介绍了核心API、使用步骤、完整示例、进阶用法以及常见问题的解决方案。开发者可以利用事件总线模式实现松耦合的组件通信。本文基于pura/harmony-utils工具库更多功能请参考官方文档与后续系列文章。
