输入关键字搜索
开发者能力认证
鸿蒙高校创新赛
HarmonyOS 7
animation
HarmonyOS行业解决方案
layoutWeight
HarmonyOS模板&组件
bindPopup
bindsheet
CTRL+K
文档管理中心

HarmonyOS

输入关键字搜索
开发者能力认证
鸿蒙高校创新赛
HarmonyOS 7
animation
HarmonyOS行业解决方案
layoutWeight
HarmonyOS模板&组件
bindPopup
bindsheet
CTRL+K
指南
指南应用框架ArkTS（方舟编程语言）ArkTS并发并发线程间通信线程间通信场景TaskPool任务与宿主线程通信

TaskPool任务与宿主线程通信

更新时间: 2026-08-29 09:41

如果Task不仅需要返回最终执行结果，还需定时通知宿主线程状态和数据变化，或分段返回大量数据（如从数据库读取大量数据），可按以下方式实现。

下面以多个图片加载任务结果实时返回为例说明。

在需要执行的Task中，添加sendData()接口将消息发送给宿主线程。在宿主线程通过onReceiveData()接口接收消息。这样宿主线程就可以通过notice()接口接收到Task发送的数据。

收起
自动换行
深色代码主题
复制
  1. export class IconItemSource {
  2.   image: string | Resource = '';
  3.   text: string | Resource = '';
  4. 

  5.   constructor(image: string | Resource = '', text: string | Resource = '') {
  6.     this.image = image;
  7.     this.text = text;
  8.   }
  9. }
IconItemSource.ets
收起
自动换行
深色代码主题
复制
  1. import { taskpool } from '@kit.ArkTS';
  2. import { IconItemSource } from './IconItemSource';
  3. // 实现接收Task消息的方法
  4. function notice(data: number): void {
  5.   console.info('子线程已加载数据，共加载图片: ', data);
  6. }
  7. 

  8. // 通过Task的sendData方法，即时通知宿主线程信息
  9. @Concurrent
  10. export function loadPictureSendData(count: number): IconItemSource[] {
  11.   let iconItemSourceList: IconItemSource[] = [];
  12.   // 遍历添加6*count个IconItem的数据
  13.   for (let index = 0; index < count; index++) {
  14.     const numStart: number = index * 6;
  15.     // 此处循环使用6张图片资源
  16.     iconItemSourceList.push(new IconItemSource('$media:startIcon', `item${numStart + 1}`));
  17.     iconItemSourceList.push(new IconItemSource('$media:background', `item${numStart + 2}`));
  18.     iconItemSourceList.push(new IconItemSource('$media:foreground', `item${numStart + 3}`));
  19.     iconItemSourceList.push(new IconItemSource('$media:startIcon', `item${numStart + 4}`));
  20.     iconItemSourceList.push(new IconItemSource('$media:background', `item${numStart + 5}`));
  21.     iconItemSourceList.push(new IconItemSource('$media:foreground', `item${numStart + 6}`));
  22. 

  23.     taskpool.Task.sendData(iconItemSourceList.length);
  24.   }
  25.   return iconItemSourceList;
  26. }
  27. 

  28. @Entry
  29. @Component
  30. struct Index {
  31.   @State message: string = 'Hello World';
  32. 

  33.   build() {
  34.     Row() {
  35.       Column() {
  36.         Text(this.message)
  37.           .fontSize(50)
  38.           .fontWeight(FontWeight.Bold)
  39.           .onClick(() => {
  40.             let iconItemSourceList: IconItemSource[];
  41.             let loadPictureTask: taskpool.Task = new taskpool.Task(loadPictureSendData, 30);
  42.             // 设置notice方法接收Task发送的消息
  43.             loadPictureTask.onReceiveData(notice);
  44.             taskpool.execute(loadPictureTask).then((res: object) => {
  45.               iconItemSourceList = res as IconItemSource[];
  46.               this.message = 'success';
  47.             }).catch((e: BusinessError) => {
  48.               this.message = 'failed';
  49.               console.error(`taskpool: execute: Code: ${e.code}, message: ${e.message}`);
  50.             })
  51.           })
  52.       }
  53.       .width('100%')
  54.     }
  55.     .height('100%')
  56.   }
  57. }
TaskSendDataUsage.ets
使用TaskPool执行多个耗时任务
Worker和宿主线程的即时消息通信
相关推荐
文档TaskPool在任务执行过程中如何跟主线程进行通信？如何操作同一块内存变量
文档使用TaskPool执行多个耗时任务
文档ArkTS中Worker线程、Taskpool线程如何与宿主线程通信
文档使用TaskPool执行独立的耗时任务
文档TaskPool简介
文档TaskPool多线程如何共享对象
文档Worker和宿主线程的即时消息通信
文档发送服务端消息
文档如何使用TaskPool在子线程调用对象成员函数
示例代码基于TaskPool实现多线程任务
简体中文
华为开发者联盟 版权所有 ©2026
问题反馈
使用条款
华为开发者联盟用户协议
关于华为开发者联盟与隐私的声明
Cookies
开源软件声明
在 指南 中进行搜索
请输入您想要搜索的关键词