• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1# 同步任务开发指导
2
3
4同步任务是指在多个线程之间协调执行的任务，其目的是确保多个任务按照一定的顺序和规则执行，例如使用锁来防止数据竞争。
5
6
7同步任务的实现需要考虑多个线程之间的协作和同步，以确保数据的正确性和程序的正确执行。
8
9由于TaskPool偏向于单个独立的任务，因此当各个同步任务之间相对独立时推荐使用TaskPool，例如一系列导入的静态方法，或者单例实现的方法。如果同步任务之间有关联性，则需要使用Worker，例如无法单例创建的类对象实现的方法。
10
11
12## 使用TaskPool处理同步任务
13
14当调度独立的同步任务，或者一系列同步任务为静态方法实现，或者可以通过单例构造唯一的句柄或类对象，可在不同任务池之间使用时，推荐使用TaskPool。
15
161. 定义并发函数，内部调用同步方法。
17
182. 创建任务，并通过TaskPool执行，再对异步结果进行操作。创建[Task](../reference/apis/js-apis-taskpool.md#task)，并通过[execute()](../reference/apis/js-apis-taskpool.md#taskpoolexecute-1)接口执行同步任务。
19
203. 执行并发操作。
21
22模拟一个包含同步调用的单实例类。
23
24
25```ts
26// Handle.ts 代码
27export default class Handle {
28  static getInstance(): void {
29    // 返回单例对象
30  }
31
32  static syncGet(): void {
33    // 同步Get方法
34  }
35
36  static syncSet(num: number): void {
37    // 同步Set方法
38  }
39}
40```
41
42
43业务使用TaskPool调用相关同步方法的代码。
44
45
46```ts
47// Index.ets代码
48import taskpool from '@ohos.taskpool';
49import Handle from './Handle'; // 返回静态句柄
50
51// 步骤1: 定义并发函数，内部调用同步方法
52@Concurrent
53function func(num: number): boolean {
54  // 调用静态类对象中实现的同步等待调用
55  Handle.syncSet(num);
56  return true;
57}
58
59// 步骤2: 创建任务并执行
60async function asyncGet(): Promise<void> {
61  // 创建task并传入函数func
62  let task: taskpool.Task = new taskpool.Task(func, 1);
63  // 执行task任务并对同步逻辑后的结果进行操作
64  console.info(String(await taskpool.execute(task)));
65}
66
67@Entry
68@Component
69struct Index {
70  @State message: string = 'Hello World';
71
72  build() {
73    Row() {
74      Column() {
75        Text(this.message)
76          .fontSize(50)
77          .fontWeight(FontWeight.Bold)
78          .onClick(() => {
79            // 步骤3: 执行并发操作
80            asyncGet();
81          })
82      }
83      .width('100%')
84      .height('100%')
85    }
86  }
87}
88```
89
90
91## 使用Worker处理关联的同步任务
92
93当一系列同步任务需要使用同一个句柄调度，或者需要依赖某个类对象调度，无法在不同任务池之间共享时，需要使用Worker。
94
951. 在主线程中创建Worker对象，同时接收Worker线程发送回来的消息。
96
97    ```ts
98    import worker from '@ohos.worker';
99
100    @Entry
101    @Component
102    struct Index {
103      @State message: string = 'Hello World';
104
105      build() {
106        Row() {
107          Column() {
108            Text(this.message)
109              .fontSize(50)
110              .fontWeight(FontWeight.Bold)
111              .onClick(() => {
112                let w: worker.ThreadWorker = new worker.ThreadWorker('entry/ets/workers/MyWorker.ts');
113                w.onmessage = (): void => {
114                  // 接收Worker子线程的结果
115                }
116                w.onerror = (): void => {
117                  // 接收Worker子线程的错误信息
118                }
119                // 向Worker子线程发送Set消息
120                w.postMessage({'type': 0, 'data': 'data'})
121                // 向Worker子线程发送Get消息
122                w.postMessage({'type': 1})
123                // 销毁线程
124                w.terminate()
125              })
126          }
127          .width('100%')
128        }
129        .height('100%')
130      }
131    }
132    ```
133
134
1352. 在Worker线程中绑定Worker对象，同时处理同步任务逻辑。
136
137    ```ts
138    // handle.ts代码
139    export default class Handle {
140      syncGet() {
141        return;
142      }
143
144      syncSet(num: number) {
145        return;
146      }
147    }
148    ```
149
150    ```ts
151    // Worker.ts代码
152    import worker, { ThreadWorkerGlobalScope, MessageEvents } from '@ohos.worker';
153    import Handle from './handle'  // 返回句柄
154
155    let workerPort : ThreadWorkerGlobalScope = worker.workerPort;
156
157    // 无法传输的句柄，所有操作依赖此句柄
158    let handler: Handle = new Handle()
159
160    // Worker线程的onmessage逻辑
161    workerPort.onmessage = (e : MessageEvents): void => {
162     switch (e.data.type as number) {
163      case 0:
164       handler.syncSet(e.data.data);
165       workerPort.postMessage('success set');
166      case 1:
167       handler.syncGet();
168       workerPort.postMessage('success get');
169     }
170    }
171    ```
172