HarmonyOS 鸿蒙Next 其他线程切换到主线程的api
HarmonyOS 鸿蒙Next 其他线程切换到主线程的api
可以通过emitter回调方式切换,emitter相关可以参考如下:
https://developer.huawei.com/consumer/cn/doc/harmonyos-references-V5/js-apis-emitter-V5#emitteron
https://developer.huawei.com/consumer/cn/doc/harmonyos-guides-V5/itc-with-emitter-V5
如果线程之间没有依赖,可以写多个emitter的发布订阅事件,不同事件监听的是不同的事件id, 如果有依赖关系,可以把监听逻辑写到有依赖关系的callback逻辑中。
import { taskpool } from '@kit.ArkTS';
import { emitter } from '@kit.BasicServicesKit';
@Concurrent
function printArgs(args: number): number {
console.info("nsm printArgs: " + args);
// 子线程处理逻辑
console.info("nsm this is child thread: " + args);
return args + 5;
}
function testChildThread(num: number) {
taskpool.execute(printArgs, num).then((value: Object) => {
console.info("nsm taskpool result: " + value);
// 子线程处理后返回数据给主线程
// 定义一个eventId为1111的事件,事件优先级为Low
let event: emitter.InnerEvent = {
eventId: 1111,
priority: emitter.EventPriority.LOW
};
let eventData: emitter.EventData = {
data: {
content: 'c',
id: 1,
isEmpty: false,
num: value
}
};
// 发送eventId为1111的事件,事件内容为eventData
emitter.emit(event, eventData);
});
}
function testTaskPool() {
console.log("nsm this is start... main thread")
let num = 20;
// 定义一个eventId为1111的事件
let event: emitter.InnerEvent = {
eventId: 1111
};
// 收到eventId为1111的事件后执行该回调
let callback = (eventData: emitter.EventData): void => {
console.info('nsm event callback:' + JSON.stringify(eventData));
// 执行主线程拿到子线程数据后的逻辑
console.info("nsm num====" + eventData?.data?.num)
num = eventData?.data?.num ? eventData?.data?.num : 0;
};
// 订阅eventId为1111的事件
emitter.on(event, callback);
testChildThread(num);
console.log("nsm this is end... main thread, num==" + num)
}
@Entry
@Component
struct Index {
build() {
Row() {
Column() {
Button("点我")
.fontSize(50)
.fontWeight(FontWeight.Bold)
.onClick(() => {
testTaskPool();
})
}
.width('100%')
}
.height('100%')
}
}
通过process.tid获取线程id,参考:
https://developer.huawei.com/consumer/cn/doc/harmonyos-references-V5/js-apis-process-V5#属性
在HarmonyOS鸿蒙Next系统中,其他线程切换到主线程的API主要通过任务分发器(TaskDispatcher)来实现。
鸿蒙系统提供了UITaskDispatcher
和MainTaskDispatcher
来处理UI相关的任务。若要从其他线程切换到主线程,可以使用getMainTaskDispatcher()
方法来获取主线程的任务分发器,然后调用其asyncDispatch()
或syncDispatch()
方法来异步或同步地执行任务。
示例代码如下:
- 异步切换到主线程:
getMainTaskDispatcher().asyncDispatch(new Runnable() {
@Override
public void run() {
// 在这里处理UI问题
}
});
- 同步切换到主线程(注意:同步调用可能会阻塞当前线程,需谨慎使用):
getMainTaskDispatcher().syncDispatch(new Runnable() {
@Override
public void run() {
// 在这里处理UI问题
}
});
以上方法允许你在其他线程中安全地更新UI元素或执行其他需要在主线程中运行的任务。如果问题依旧没法解决请联系官网客服,官网地址是:https://www.itying.com/category-93-b0.html。