From d82399539fc26d9a3a9a906e98eb2a34fcc99014 Mon Sep 17 00:00:00 2001 From: le_02 Date: Tue, 6 Jan 2026 15:15:10 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=BA=86=E9=83=A8=E5=88=86?= =?UTF-8?q?=E7=9A=84=E4=BB=A3=E7=A0=81=E5=90=8C=E6=BA=90=E7=89=87=E6=AE=B5?= =?UTF-8?q?=E7=9A=84=E5=86=85=E5=AE=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: le_02 --- entry/src/main/ets/pages/DecodeBusinessTypePage.ets | 2 +- entry/src/main/ets/utils/TcpServerUtil.ets | 5 +++-- entry/src/main/ets/workers/ClientWorker.ets | 2 -- hvigorfile.ts | 6 +++--- 4 files changed, 7 insertions(+), 8 deletions(-) diff --git a/entry/src/main/ets/pages/DecodeBusinessTypePage.ets b/entry/src/main/ets/pages/DecodeBusinessTypePage.ets index ff16d24..3319765 100644 --- a/entry/src/main/ets/pages/DecodeBusinessTypePage.ets +++ b/entry/src/main/ets/pages/DecodeBusinessTypePage.ets @@ -41,7 +41,6 @@ export default struct DecodeBusinessTypePage { } async execSerialize(): Promise { - // [Start decodeMainThread] let message_simple = new UserProfile(); message_simple.age = 25; message_simple.name = 'Alice'; @@ -49,6 +48,7 @@ export default struct DecodeBusinessTypePage { message_simple.height = 175; message_simple.is_student = true; let encodeBuf = UserProfile.encode(message_simple); + // [Start decodeMainThread] let res = await taskpool.execute(subThread, encodeBuf) as UserProfile | undefined; // [End decodeMainThread] this.buildString(res) diff --git a/entry/src/main/ets/utils/TcpServerUtil.ets b/entry/src/main/ets/utils/TcpServerUtil.ets index 7f2ff1e..7903c96 100644 --- a/entry/src/main/ets/utils/TcpServerUtil.ets +++ b/entry/src/main/ets/utils/TcpServerUtil.ets @@ -30,8 +30,9 @@ class TcpServerUtil { public isCreate: boolean = false; public readonly ADDRESS = '127.0.0.1'; public readonly PORT = 8080; + // [Start bigDataMainThread] workerInstance = new worker.ThreadWorker('entry/ets/workers/ServerWorker.ets'); - + // [StartExclude bigDataMainThread] public create(): Promise { return this.tcpServer.listen({ address: this.ADDRESS, @@ -90,7 +91,7 @@ class TcpServerUtil { Logger.info('tcpServer received message--:' + str); let res: RequestInfo = JSON.parse(str); if (res.requestType == RequestType.GET_BATCH_DANMU) { - // [Start bigDataMainThread] + // [EndExclude bigDataMainThread] let arrayBuffer = await taskpool.execute(encodeDanmuBatch, DataGenerateUtil.generateDanmuBatch(res.data)) as ArrayBuffer | undefined; if (arrayBuffer) { diff --git a/entry/src/main/ets/workers/ClientWorker.ets b/entry/src/main/ets/workers/ClientWorker.ets index 6ac9723..d142b5e 100644 --- a/entry/src/main/ets/workers/ClientWorker.ets +++ b/entry/src/main/ets/workers/ClientWorker.ets @@ -31,9 +31,7 @@ const workerPort: ThreadWorkerGlobalScope = worker.workerPort; // [Start bigDataChildTask] workerPort.onmessage = (event: MessageEvents) => { const data: ArrayBuffer = event.data; - Logger.info(`client recv ==>${new Uint8Array(data).slice(0, 12)}`); const unpackedChunk = unpackArrayBuffer(data); - Logger.info(`解析分片${unpackedChunk.chunkIndex}，数字dataId：${unpackedChunk.dataId}`); workerPort.postMessage(unpackedChunk.chunkIndex); const reassembledBuffer = ArrayBufferAssemblerUtil.receiveChunk( diff --git a/hvigorfile.ts b/hvigorfile.ts index b56f926..099fd6f 100644 --- a/hvigorfile.ts +++ b/hvigorfile.ts @@ -26,9 +26,9 @@ export default { appPlugin({ ignoreModuleNames: [] }), // [EndExclude configPlugin] turboTransProtobufPlugin({ - saveDir: 'src/main/ets/model', - scanDir: ['protofile'], - sendable: true, + saveDir: 'src/main/ets/model', // 保存路径 + scanDir: ['protofile'], // 扫描路径 + sendable: true, // 是否开启sendable }), ] } -- Gitee