多线程取消TaskPool任务场景
由于任务池TaskPool的任务对象Task不支持跨线程传递,因此无法在子线程中取消任务。从 API version 18 开始,Task新增了任务ID属性,支持通过任务ID在子线程中取消任务。以下示例提供多线程取消已提交给TaskPool中的任务开发指导,开发者可将已创建任务的任务ID存储在Sendable对象中,需要取消任务时,通过Sendable对象来多线程取消任务。
-
定义一个Sendable类,在类属性中存储任务ID。
// Mock.ets @Sendable export class SendableTest { // 储存任务ID private taskId: number = 0; constructor(id: number) { this.taskId = id; } public getTaskId(): number { return this.taskId; } } -
在UI主线程向TaskPool提交一个延时任务,并在子线程取消该任务。
// Index.ets import { taskpool } from '@kit.ArkTS'; import { SendableTest } from './Mock' @Concurrent function cancel(send: SendableTest) { console.info("cancel task finished"); // 通过任务ID多线程取消任务 taskpool.cancel(send.getTaskId()); } @Concurrent function delayed() { console.info("delayed task finished"); } @Entry @Component struct Index { @State message: string = 'Hello World!'; @State books: string[] = []; build() { Column({ space: 1 }) { Button(this.books[3]) .fontSize(20) .padding(10) .fontWeight(FontWeight.Bold) .onClick(async () => { let task = new taskpool.Task(delayed); taskpool.executeDelayed(2000, task).catch((e: BusinessError) => { console.error(`taskpool execute error, message is: ${e.message}`); // taskpool execute error, message is: taskpool:: task has been canceled }); let send = new SendableTest(task.taskId); taskpool.execute(cancel, send); }) } .height('100%') .width('100%') } }