{"id":113449,"date":"2026-10-06T13:01:20","date_gmt":"2026-10-06T05:01:20","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/113449.html"},"modified":"2026-10-06T13:01:20","modified_gmt":"2026-10-06T05:01:20","slug":"harmonyos-7-jsonpulse-%e9%80%82%e9%85%8d%e5%ae%9e%e5%bd%9504%ef%bc%9athreadsafefunction%e7%ba%bf%e7%a8%8b%e5%ae%89%e5%85%a8%e5%9b%9e%e8%b0%83","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/113449.html","title":{"rendered":"HarmonyOS 7 JsonPulse \u9002\u914d\u5b9e\u5f5504\uff1aThreadSafeFunction\u7ebf\u7a0b\u5b89\u5168\u56de\u8c03"},"content":{"rendered":"

03 \u628a 48MB JSON \u7684\u91cd\u6d3b\u79fb\u5230\u4e86 napi_async_work\u3002<\/p>\n

\u5f53\u524d JsonPulse \u7684\u94fe\u8def\u5df2\u7ecf\u53d8\u6210：<\/p>\n

ArkTS Uint8Array
\n\u2192 Native Owned Buffer
\n\u2192 napi_create_async_work
\n\u2192 Worker Parse
\n\u2192 complete_cb
\n\u2192 Promise<\/p>\n

182.4ms \u7684\u89e3\u6790\u4e0d\u518d\u957f\u671f\u5835\u4f4f ArkTS \u8c03\u7528\u7ebf\u7a0b，UI \u8bca\u65ad\u5fc3\u8df3\u4ecd\u7136\u7ef4\u6301\u5728 58.9fps \u5de6\u53f3\u3002<\/p>\n

\u4f46\u5f02\u6b65\u4efb\u52a1\u4e00\u65e6\u7ee7\u7eed\u53d8\u5927，\u4ea7\u54c1\u5c42\u9a6c\u4e0a\u4f1a\u63d0\u51fa\u4e24\u4e2a\u65b0\u8981\u6c42：<\/p>\n

\u6211\u8981\u770b\u5230\u8fdb\u5ea6\u3002<\/p>\n

\u6211\u8981\u80fd\u53d6\u6d88\u3002<\/p>\n

\u8fd9\u65f6\u666e\u901a napi_async_work \u53ea\u63d0\u4f9b：<\/p>\n

execute
\ncomplete<\/p>\n

\u4e0d\u8d1f\u8d23\u201cWorker \u4e2d\u95f4\u600e\u4e48\u5b89\u5168\u901a\u77e5 ArkTS\u201d\u3002<\/p>\n

HarmonyOS \u5f53\u524d Node-API \/ libuv \u6587\u6863\u7ed9\u51fa\u7684\u7ebf\u7a0b\u5b89\u5168\u56de\u8c03\u65b9\u6848\u5c31\u662f napi_threadsafe_function\u3002\u5b83\u53ef\u4ee5\u4ece Native \u5b50\u7ebf\u7a0b\u5b89\u5168\u5730\u5411 ArkTS \u6240\u5728\u4e8b\u4ef6\u5faa\u73af\u6295\u9012\u6570\u636e；\u5b98\u65b9\u4e5f\u5f3a\u8c03，\u5927\u591a\u6570 NAPI \u63a5\u53e3\u4e0d\u80fd\u968f\u610f\u8de8\u7ebf\u7a0b\u8c03\u7528，TSFN \u5c31\u662f\u4e13\u95e8\u89e3\u51b3\u8fd9\u79cd\u201c\u5b50\u7ebf\u7a0b\u901a\u77e5 JS\/ArkTS\u201d\u573a\u666f\u7684\u3002<\/p>\n

04 \u56e0\u6b64\u5728 03 \u7684 async work \u4e0a\u7ee7\u7eed\u6f14\u8fdb：<\/p>\n

\u5f02\u6b65\u89e3\u6790\u4ecd\u7531 Worker \u6267\u884c；\u8fdb\u5ea6\u53ea\u901a\u8fc7 TSFN \u56de\u4e3b\u7ebf\u7a0b；\u53d6\u6d88\u4f7f\u7528 Native \u539f\u5b50\u6807\u8bb0；\u4efb\u52a1\u7ed3\u675f\u540e TSFN \u6210\u5bf9 release\u3002<\/p>\n

\u672c\u8f6e\u7edf\u4e00\u6570\u636e：<\/p>\n

taskId:
\nnative_20261003_04<\/p>\n

sourceFile:
\ntelemetry_96mb.json<\/p>\n

inputBytes:
\n100,663,296<\/p>\n

inputSize:
\n96MB<\/p>\n

records:
\n496,000<\/p>\n

workerThreads:
\n1<\/p>\n

progressRawTicks:
\n64<\/p>\n

progressStep:
\n5%<\/p>\n

progressCallbacks:
\n20<\/p>\n

tsfnQueueMax:
\n8<\/p>\n

tsfnCreated:
\ntrue<\/p>\n

tsfnCalls:
\n20<\/p>\n

tsfnQueueFull:
\n0<\/p>\n

cancelRequestedAt:
\n61%<\/p>\n

cancelObservedAt:
\n62%<\/p>\n

cancelLatency:
\n11.8ms<\/p>\n

firstRunStatus:
\nCANCELLED<\/p>\n

retryAfterCancel:
\ntrue<\/p>\n

retryRecords:
\n496,000<\/p>\n

retryParseCost:
\n344.8ms<\/p>\n

progressOrderErrors:
\n0<\/p>\n

crossThreadNapiViolations:
\n0<\/p>\n

tsfnReleased:
\ntrue<\/p>\n

finalizeCount:
\n1<\/p>\n

status:
\nTHREADSAFE_PROGRESS_READY<\/p>\n

\"\"<\/p>\n

\u4e00\u300104 \u5148\u628a\u201c\u8fdb\u5ea6\u901a\u77e5\u201d\u548c\u201c\u89e3\u6790\u7ebf\u7a0b\u201d\u5f7b\u5e95\u5206\u5f00<\/h3>\n

\u6700\u5371\u9669\u7684\u9519\u8bef\u5199\u6cd5\u662f：<\/p>\n

Worker Thread<\/p>\n

napi_create_object(env)
\nnapi_call_function(env)
\n\u66f4\u65b0 ArkTS callback<\/p>\n

\u770b\u8d77\u6765\u53ea\u662f\u60f3\u56de\u4e00\u4e2a\u767e\u5206\u6bd4\u3002<\/p>\n

\u5b9e\u9645\u5374\u8de8\u7ebf\u7a0b\u76f4\u63a5\u4f7f\u7528\u539f env\u3002<\/p>\n

HarmonyOS \u5f53\u524d DFX \u6587\u6863\u4f1a\u4e13\u95e8\u68c0\u6d4b\u8fd9\u7c7b\u9519\u8bef，\u5e76\u63d0\u793a：<\/p>\n

current napi interface cannot run in multi-thread<\/p>\n

\u6240\u4ee5 JsonPulse \u7684 Worker \u6709\u4e00\u6761\u786c\u89c4\u5219：<\/p>\n

\u9664\u7ebf\u7a0b\u5b89\u5168\u51fd\u6570\u7cfb\u5217 API \u5916，\u4e0d\u5728 Worker \u7ebf\u7a0b\u78b0 ArkTS \/ JS \u503c\u3002<\/p>\n

\u4e8c\u3001TSFN \u5728\u4efb\u52a1\u521b\u5efa\u9636\u6bb5\u7531 ArkTS \u7ebf\u7a0b\u5efa\u7acb<\/h3>\n

\u7b2c\u4e00\u6bb5\u4ee3\u7801\u89e3\u51b3\u7684\u662f：<\/p>\n

\u5728\u539f env \u6240\u5728\u7ebf\u7a0b\u521b\u5efa TSFN，\u628a ArkTS onProgress callback \u548c Native Context \u7ed1\u5b9a\u8d77\u6765\u3002<\/p>\n

struct<\/span> ProgressContext<\/span> {<\/span>
\n napi_async_work work =<\/span> nullptr<\/span>;<\/span><\/p>\n

napi_deferred deferred =<\/span> nullptr<\/span>;<\/span><\/p>\n

napi_threadsafe_function tsfn =<\/span>
\n nullptr<\/span>;<\/span><\/p>\n

std::<\/span>atomic<<\/span>bool<\/span>><\/span>
\n cancelRequested {<\/span>
\n false<\/span>
\n }<\/span>;<\/span><\/p>\n

uint64_t<\/span> records =<\/span> 0<\/span>;<\/span><\/p>\n

int<\/span> lastProgress =<\/span> 0<\/span>;<\/span><\/p>\n

std::<\/span>string error;<\/span>
\n}<\/span>;<\/span><\/p>\n

static<\/span> bool<\/span> CreateProgressTsfn<\/span>(<\/span>
\n napi_env env,<\/span>
\n napi_value callback,<\/span>
\n ProgressContext*<\/span> ctx)<\/span>
\n{<\/span>
\n napi_value name;<\/span><\/p>\n

napi_create_string_utf8<\/span>(<\/span>
\n env,<\/span>
\n "JsonPulseProgress"<\/span>,<\/span>
\n NAPI_AUTO_LENGTH,<\/span>
\n &<\/span>name)<\/span>;<\/span><\/p>\n

napi_status status =<\/span>
\n napi_create_threadsafe_function<\/span>(<\/span>
\n env,<\/span>
\n callback,<\/span>
\n nullptr<\/span>,<\/span>
\n name,<\/span>
\n 8<\/span>,<\/span>
\n 1<\/span>,<\/span>
\n ctx,<\/span>
\n FinalizeTsfn,<\/span>
\n nullptr<\/span>,<\/span>
\n CallProgressOnJs,<\/span>
\n &<\/span>ctx-><\/span>tsfn)<\/span>;<\/span><\/p>\n

return<\/span> status ==<\/span> napi_ok;<\/span>
\n}<\/span><\/p>\n

\u8fd9\u91cc：<\/p>\n

max_queue_size=8
\ninitial_thread_count=1<\/p>\n

\u90fd\u662f JsonPulse \u5f53\u524d\u6d4b\u8bd5\u914d\u7f6e\u3002<\/p>\n

\u4e0d\u662f\u7cfb\u7edf\u56fa\u5b9a\u63a8\u8350\u503c\u3002<\/p>\n

\u4e09\u3001\u4e3a\u4ec0\u4e48\u8fdb\u5ea6\u53ea\u6bcf 5% \u56de\u4e00\u6b21<\/h3>\n

Parser \u5185\u90e8\u53ef\u80fd\u7ecf\u5386：<\/p>\n

64 \u6b21 chunk tick<\/p>\n

\u5982\u679c\u6bcf\u4e2a tick \u90fd\u8c03\u7528 TSFN：<\/p>\n

64 callbacks<\/p>\n

UI \u6ca1\u5fc5\u8981\u5237\u65b0\u8fd9\u4e48\u7ec6\u3002<\/p>\n

JsonPulse \u5f53\u524d\u7b56\u7565：<\/p>\n

progressRawTicks=64
\nprogressStep=5%
\nprogressCallbacks=20<\/p>\n

Worker \u53ea\u6709\u8de8\u8fc7\u65b0\u7684 5% \u6863\u4f4d\u624d\u6295\u9012\u3002<\/p>\n

\u8fd9\u6837\u65e2\u80fd\u8ba9\u7528\u6237\u611f\u89c9\u4efb\u52a1\u5728\u63a8\u8fdb，\u53c8\u4e0d\u4f1a\u628a\u56de\u8c03\u961f\u5217\u53d8\u6210\u65b0\u7684\u6027\u80fd\u70ed\u70b9\u3002<\/p>\n

\u56db\u3001Worker \u7ebf\u7a0b\u53ea new Native ProgressEvent，\u518d\u8c03\u7528 TSFN<\/h3>\n

\u7b2c\u4e8c\u6bb5\u4ee3\u7801\u662f 04 \u7684\u6838\u5fc3\u3002<\/p>\n

struct<\/span> ProgressEvent<\/span> {<\/span>
\n int<\/span> percent =<\/span> 0<\/span>;<\/span>
\n uint64_t<\/span> records =<\/span> 0<\/span>;<\/span>
\n}<\/span>;<\/span><\/p>\n

static<\/span> void<\/span> ReportProgress<\/span>(<\/span>
\n ProgressContext*<\/span> ctx,<\/span>
\n int<\/span> percent,<\/span>
\n uint64_t<\/span> records)<\/span>
\n{<\/span>
\n if<\/span> (<\/span>
\n percent <=<\/span>
\n ctx-><\/span>lastProgress)<\/span> {<\/span>
\n return<\/span>;<\/span>
\n }<\/span><\/p>\n

if<\/span> (<\/span>
\n percent –<\/span>
\n ctx-><\/span>lastProgress <<\/span>
\n 5<\/span> &&<\/span>
\n percent !=<\/span> 100<\/span>)<\/span> {<\/span>
\n return<\/span>;<\/span>
\n }<\/span><\/p>\n

ctx-><\/span>lastProgress =<\/span>
\n percent;<\/span><\/p>\n

auto<\/span>*<\/span> event =<\/span>
\n new<\/span> ProgressEvent {<\/span>
\n percent,<\/span>
\n records
\n }<\/span>;<\/span><\/p>\n

napi_status status =<\/span>
\n napi_call_threadsafe_function<\/span>(<\/span>
\n ctx-><\/span>tsfn,<\/span>
\n event,<\/span>
\n napi_tsfn_nonblocking)<\/span>;<\/span><\/p>\n

if<\/span> (<\/span>status !=<\/span> napi_ok)<\/span> {<\/span>
\n delete<\/span> event;<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

\u8fd9\u91cc Worker \u521b\u5efa\u7684\u662f：<\/p>\n

C++ ProgressEvent<\/p>\n

\u4e0d\u662f：<\/p>\n

napi_value<\/p>\n

\u771f\u6b63 ArkTS Value \u7684\u6784\u9020\u53d1\u751f\u5728 CallProgressOnJs\u3002<\/p>\n

\u4e94\u3001CallProgressOnJs \u624d\u662f\u628a Native \u6570\u636e\u53d8\u6210 ArkTS \u6570\u636e\u7684\u5730\u65b9<\/h3>\n

TSFN \u56de\u8c03\u8fd0\u884c\u5728 ArkTS \/ JS \u4e8b\u4ef6\u5faa\u73af\u5bf9\u5e94\u7ebf\u7a0b\u3002<\/p>\n

static<\/span> void<\/span> CallProgressOnJs<\/span>(<\/span>
\n napi_env env,<\/span>
\n napi_value jsCallback,<\/span>
\n void<\/span>*<\/span>,<\/span>
\n void<\/span>*<\/span> data)<\/span>
\n{<\/span>
\n auto<\/span>*<\/span> event =<\/span>
\n static_cast<\/span><<\/span>
\n ProgressEvent*<\/span>><\/span><\/span><\/span>(<\/span>data)<\/span>;<\/span><\/p>\n

napi_value payload;<\/span>
\n napi_create_object<\/span>(<\/span>
\n env,<\/span>
\n &<\/span>payload)<\/span>;<\/span><\/p>\n

SetInt32<\/span>(<\/span>
\n env,<\/span>
\n payload,<\/span>
\n "percent"<\/span>,<\/span>
\n event-><\/span>percent)<\/span>;<\/span><\/p>\n

SetUint64<\/span>(<\/span>
\n env,<\/span>
\n payload,<\/span>
\n "records"<\/span>,<\/span>
\n event-><\/span>records)<\/span>;<\/span><\/p>\n

napi_value undefined;<\/span>
\n napi_get_undefined<\/span>(<\/span>
\n env,<\/span>
\n &<\/span>undefined)<\/span>;<\/span><\/p>\n

napi_call_function<\/span>(<\/span>
\n env,<\/span>
\n undefined,<\/span>
\n jsCallback,<\/span>
\n 1<\/span>,<\/span>
\n &<\/span>payload,<\/span>
\n nullptr<\/span>)<\/span>;<\/span><\/p>\n

delete<\/span> event;<\/span>
\n}<\/span><\/p>\n

\u8fd9\u5c31\u662f ThreadSafeFunction \u7684\u771f\u6b63\u4ef7\u503c：<\/p>\n

Worker \u53ea\u4f20 Native Data<\/p>\n

ArkTS Thread
\n\u8d1f\u8d23\u6784\u9020 JS Value \u548c\u6267\u884c callback<\/p>\n

\u516d\u3001\u53d6\u6d88\u4f7f\u7528 atomic flag，\u4e0d\u9760\u5f3a\u6740 Worker<\/h3>\n

\u7b2c\u4e00\u6b21\u8fd0\u884c\u6211\u6545\u610f\u5728：<\/p>\n

61%<\/p>\n

\u70b9\u51fb\u53d6\u6d88\u3002<\/p>\n

ArkTS \u8c03：<\/p>\n

cancel(taskId)<\/p>\n

Native \u4e0d\u4f1a：<\/p>\n

pthread_cancel
\nterminate<\/p>\n

\u800c\u662f：<\/p>\n

cancelRequested.store(true)<\/p>\n

Worker \u6bcf\u4e2a chunk \u8fb9\u754c\u68c0\u67e5\u4e00\u6b21\u3002<\/p>\n

\u6700\u7ec8：<\/p>\n

cancelRequestedAt=61%
\ncancelObservedAt=62%
\ncancelLatency=11.8ms<\/p>\n

\u4e5f\u5c31\u662f\u8bf4，\u8fd9\u662f\u534f\u4f5c\u5f0f\u53d6\u6d88\u3002<\/p>\n

\u89e3\u6790\u5668\u81ea\u5df1\u5728\u5b89\u5168\u68c0\u67e5\u70b9\u9000\u51fa\u3002<\/p>\n

\u4e03\u3001\u53d6\u6d88\u4ee5\u540e async_work \u7684 complete_cb \u4ecd\u7136\u8981\u8d1f\u8d23\u6536\u53e3<\/h3>\n

Worker \u68c0\u6d4b：<\/p>\n

cancelRequested=true<\/p>\n

\u4ee5\u540e\u8bbe\u7f6e：<\/p>\n

status=CANCELLED<\/p>\n

\u7136\u540e\u6b63\u5e38\u8fd4\u56de execute_cb\u3002<\/p>\n

complete_cb \u4ecd\u7136\u6267\u884c：<\/p>\n

Resolve \/ Reject
\ndelete async work
\nrelease TSFN
\nrelease native buffer
\ndelete context<\/p>\n

\u53d6\u6d88\u4e0d\u662f：<\/p>\n

\u76f4\u63a5\u8df3\u8fc7 complete<\/p>\n

\u5426\u5219\u8d44\u6e90\u6e05\u7406\u4e00\u5b9a\u4f1a\u6f0f\u3002<\/p>\n

\u516b\u3001napi_cancel_async_work \u548c\u4e1a\u52a1\u53d6\u6d88\u4e0d\u662f\u4e00\u56de\u4e8b<\/h3>\n

HarmonyOS \u5f53\u524d\u5b98\u65b9\u5f02\u6b65\u4efb\u52a1\u6587\u6863\u8bf4\u660e：<\/p>\n

napi_cancel_async_work \u8c03\u7528\u672c\u8eab\u4e0d\u4ee3\u8868\u5e95\u5c42\u4e00\u5b9a\u6210\u529f\u53d6\u6d88，\u771f\u6b63\u72b6\u6001\u9700\u8981\u5728 complete callback \u91cc\u5224\u65ad\u3002<\/p>\n

JsonPulse 04 \u7684 61% \u53d6\u6d88\u53d1\u751f\u65f6，\u4efb\u52a1\u5df2\u7ecf\u5728 Worker \u5185\u6267\u884c\u3002<\/p>\n

\u6240\u4ee5\u9879\u76ee\u4e0d\u4f9d\u8d56：<\/p>\n

napi_cancel_async_work<\/p>\n

\u5b8c\u6210\u201c\u6b63\u5728\u6267\u884c\u4efb\u52a1\u201d\u7684\u4e2d\u65ad\u3002<\/p>\n

\u800c\u662f\u4f7f\u7528：<\/p>\n

atomic cancel flag<\/p>\n

\u8ba9\u4e1a\u52a1\u4ee3\u7801\u81ea\u5df1\u5728 chunk \u8fb9\u754c\u9000\u51fa\u3002<\/p>\n

\u5982\u679c\u4efb\u52a1\u8fd8\u5728 queue \u672a\u6267\u884c，\u53ef\u4ee5\u53e6\u5916\u8003\u8651 Node-API cancel\u3002<\/p>\n

\u4e24\u5c42\u8bed\u4e49\u8981\u5206\u5f00\u3002<\/p>\n

\u4e5d\u3001\u7b2c\u4e00\u6b21 CANCELLED \u540e\u4e3a\u4ec0\u4e48\u8fd8\u8981\u505a\u4e00\u6b21\u5b8c\u6574 Retry<\/h3>\n

\u5982\u679c\u53ea\u9a8c\u8bc1：<\/p>\n

\u80fd\u53d6\u6d88<\/p>\n

\u8fd8\u4e0d\u591f\u3002<\/p>\n

\u771f\u6b63\u4ea7\u54c1\u91cc\u7528\u6237\u5f88\u53ef\u80fd\u9a6c\u4e0a\u70b9：<\/p>\n

\u91cd\u65b0\u89e3\u6790<\/p>\n

\u6240\u4ee5\u672c\u8f6e\u7b2c\u4e00\u6b21：<\/p>\n

62%
\nCANCELLED<\/p>\n

\u968f\u540e\u7acb\u523b\u65b0\u5efa：<\/p>\n

\u65b0\u7684 Context
\n\u65b0\u7684 async_work
\n\u65b0\u7684 TSFN<\/p>\n

\u7b2c\u4e8c\u6b21\u5b8c\u6574\u8dd1\u5230：<\/p>\n

100%
\n496,000 records
\n344.8ms
\nPASS<\/p>\n

\u53d6\u6d88\u8fc7\u4e00\u6b21\u4e0d\u4f1a\u6c61\u67d3\u4e0b\u4e00\u8f6e\u3002<\/p>\n

\u5341\u3001TSFN \u961f\u5217\u6ee1\u4e5f\u5fc5\u987b\u6709\u7b56\u7565<\/h3>\n

\u672c\u8f6e：<\/p>\n

max_queue_size=8<\/p>\n

tsfnCalls=20<\/p>\n

tsfnQueueFull=0<\/p>\n

\u539f\u56e0\u662f：<\/p>\n

5% \u6b65\u8fdb
\nUI callback \u5f88\u8f7b<\/p>\n

\u5982\u679c\u672a\u6765\u6539\u6210：<\/p>\n

\u6bcf 0.1% \u4e00\u6b21<\/p>\n

\u961f\u5217\u53ef\u80fd\u8ddf\u4e0d\u4e0a\u3002<\/p>\n

\u4f7f\u7528 napi_tsfn_nonblocking \u65f6，\u961f\u5217\u6ee1\u4ee5\u540e\u4e0d\u80fd\u5047\u88c5\u8fdb\u5ea6\u4e00\u5b9a\u90fd\u9001\u5230\u4e86\u3002<\/p>\n

JsonPulse \u7684\u8bbe\u8ba1\u662f：<\/p>\n

\u8fdb\u5ea6\u5141\u8bb8\u5408\u5e76；<\/p>\n

\u6700\u7ec8\u7ed3\u679c\u4e0d\u5141\u8bb8\u4e22\u3002<\/p>\n

\u6240\u4ee5\u4e2d\u95f4 Progress \u53ef\u4ee5\u964d\u91c7\u6837，Complete \u4ecd\u7136\u8d70 async_work \u7684\u6700\u7ec8\u56de\u8c03\u3002<\/p>\n

\u5341\u4e00\u3001\u8fdb\u5ea6\u5fc5\u987b\u4fdd\u8bc1\u5355\u8c03<\/h3>\n

\u672c\u8f6e：<\/p>\n

progressOrderErrors=0<\/p>\n

\u5373：<\/p>\n

5
\n10
\n15
\n…
\n100<\/p>\n

\u4e0d\u4f1a\u51fa\u73b0：<\/p>\n

40
\n35
\n45<\/p>\n

\u5982\u679c\u591a\u4e2a Worker \u5e76\u53d1\u4e0a\u62a5，\u6392\u5e8f\u4f1a\u590d\u6742\u5f88\u591a\u3002<\/p>\n

\u5f53\u524d：<\/p>\n

workerThreads=1<\/p>\n

\u5148\u628a\u5355 Worker \u8def\u5f84\u505a\u7a33\u3002<\/p>\n

06 \u518d\u8003\u8651\u4e0d\u540c\u4efb\u52a1\u5e76\u53d1，\u800c\u4e0d\u662f\u5728 04 \u4e00\u6b21\u628a\u6240\u6709\u590d\u6742\u5ea6\u53e0\u4e0a\u6765\u3002<\/p>\n

\u5341\u4e8c\u3001TSFN \u5fc5\u987b release，\u800c\u4e14\u53ea release \u4e00\u6b21<\/h3>\n

\u5b98\u65b9 TSFN \u63a5\u53e3\u63d0\u4f9b：<\/p>\n

napi_acquire_threadsafe_function<\/p>\n

napi_call_threadsafe_function<\/p>\n

napi_release_threadsafe_function<\/p>\n

\u751f\u547d\u5468\u671f\u672c\u8eab\u5c31\u662f\u534f\u8bae\u7684\u4e00\u90e8\u5206\u3002<\/p>\n

JsonPulse \u5f53\u524d：<\/p>\n

initial_thread_count=1<\/p>\n

\u4efb\u52a1\u7ed3\u675f\u4ee5\u540e：<\/p>\n

napi_release_threadsafe_function<\/span>(<\/span>
\n ctx-><\/span>tsfn,<\/span>
\n napi_tsfn_release)<\/span>;<\/span><\/p>\n

\u6700\u7ec8：<\/p>\n

tsfnReleased=true
\nfinalizeCount=1<\/p>\n

\u6ca1\u6709\u91cd\u590d\u91ca\u653e\u3002<\/p>\n

\u5341\u4e09\u3001Finalize \u56de\u8c03\u53ea\u505a TSFN \u81ea\u5df1\u7684\u5c3e\u90e8\u6e05\u7406<\/h3>\n

FinalizeTsfn \u4e0d\u662f\u4efb\u52a1 complete \u7684\u66ff\u4ee3\u54c1\u3002<\/p>\n

\u5b83\u53ea\u505a\u548c ThreadSafeFunction \u81ea\u8eab\u76f8\u5173\u7684\u4e0a\u4e0b\u6587\u6536\u53e3\u3002<\/p>\n

\u89e3\u6790 Promise\u3001Native Buffer \u548c async_work \u4ecd\u7136\u7531\u4e3b\u4efb\u52a1 Context \u7ba1\u3002<\/p>\n

\u8fd9\u79cd Owner \u62c6\u5206\u5f88\u91cd\u8981\u3002<\/p>\n

\u5426\u5219：<\/p>\n

TSFN finalize
\n\u548c
\nasync complete<\/p>\n

\u90fd\u60f3 delete \u540c\u4e00\u4e2a Context，\u5c31\u4f1a\u51fa\u73b0 double free\u3002<\/p>\n

\u5341\u56db\u3001crossThreadNapiViolations=0 \u600e\u4e48\u9a8c\u8bc1<\/h3>\n

HarmonyOS \u5f53\u524d Native DFX \u6587\u6863\u5df2\u7ecf\u5bf9\u8de8\u7ebf\u7a0b NAPI \u4f7f\u7528\u63d0\u4f9b\u4e13\u95e8\u8bca\u65ad\u3002<\/p>\n

JsonPulse \u8c03\u8bd5\u9636\u6bb5\u4f1a\u542f\u7528\u5bf9\u5e94\u591a\u7ebf\u7a0b\u68c0\u6d4b\u80fd\u529b，\u5e76\u914d\u5408：<\/p>\n

TSan
\nNative \u5d29\u6e83\u65e5\u5fd7
\nHiLog<\/p>\n

\u68c0\u67e5：<\/p>\n

Worker \u662f\u5426\u76f4\u63a5\u4f7f\u7528 env<\/p>\n

TSFN \u662f\u5426\u5728 dead env \u4e0a\u8c03\u7528<\/p>\n

Context \u662f\u5426\u6709 data race<\/p>\n

\u672c\u8f6e：<\/p>\n

crossThreadNapiViolations=0<\/p>\n

\u624d\u8fdb\u5165\u6700\u7ec8 Ready\u3002<\/p>\n

\u5341\u4e94\u3001DevEco \u56fe\u91cd\u70b9\u770b 61% \/ 62% \u548c Retry<\/h3>\n

\u5f00\u53d1\u56fe：<\/p>\n

\"\"<\/p>\n

\u7b2c\u4e00\u6b21\u8fd0\u884c：<\/p>\n

cancel request:
\n61%<\/p>\n

worker observed:
\n62%<\/p>\n

latency:
\n11.8ms<\/p>\n

status:
\nCANCELLED<\/p>\n

\u7b2c\u4e8c\u6b21：<\/p>\n

100%<\/p>\n

records:
\n496,000<\/p>\n

344.8ms<\/p>\n

PASS<\/p>\n

\u5e95\u90e8\u540c\u65f6\u6709：<\/p>\n

tsfnQueueFull=0
\nprogressOrderErrors=0
\ncrossThreadNapiViolations=0
\ntsfnReleased=true<\/p>\n

\u8fd9\u6bd4\u5355\u72ec\u4e00\u6761\u201c\u53d6\u6d88\u6210\u529f\u201d\u66f4\u5b8c\u6574\u3002<\/p>\n

\u5341\u516d\u3001\u624b\u673a\u8fd0\u884c\u56fe\u628a\u4e00\u6b21\u53d6\u6d88\u548c\u4e00\u6b21\u91cd\u8bd5\u653e\u5728\u540c\u4e00\u9875<\/h3>\n

\u6700\u7ec8\u8fd0\u884c\u56fe：<\/p>\n

\"\"<\/p>\n

\u9876\u90e8：<\/p>\n

telemetry_96mb.json
\n96MB
\n496,000 records<\/p>\n

\u7b2c\u4e00\u6b21：<\/p>\n

61% request<\/p>\n

62% observed<\/p>\n

11.8ms<\/p>\n

CANCELLED<\/p>\n

\u7b2c\u4e8c\u6b21：<\/p>\n

100%<\/p>\n

344.8ms<\/p>\n

PASS<\/p>\n

\u5e95\u90e8\u8d44\u6e90\u533a：<\/p>\n

TSFN created
\ncalls=20
\nqueueMax=8
\nqueueFull=0
\norderErrors=0
\ncrossThreadViolation=0
\nreleased=true
\nfinalize=1<\/p>\n

\u6700\u7ec8：<\/p>\n

THREADSAFE_PROGRESS_READY<\/p>\n

\u5341\u4e03\u300104 \u6700\u540e\u56fa\u5b9a\u4e5d\u7ec4\u7ebf\u7a0b\u6d4b\u8bd5<\/h3>\n

\u7b2c\u4e00\u7ec4，20 \u4e2a\u8fdb\u5ea6 Callback \u987a\u5e8f\u6b63\u786e\u3002<\/p>\n

\u7b2c\u4e8c\u7ec4，Worker \u4e0d\u76f4\u63a5\u521b\u5efa napi_value\u3002<\/p>\n

\u7b2c\u4e09\u7ec4，61% \u8bf7\u6c42\u53d6\u6d88，Worker \u80fd\u5728\u5b89\u5168\u70b9\u89c2\u5bdf\u3002<\/p>\n

\u7b2c\u56db\u7ec4，\u53d6\u6d88\u540e complete \u4ecd\u7136\u6267\u884c\u3002<\/p>\n

\u7b2c\u4e94\u7ec4，\u53d6\u6d88\u540e\u53ef\u4ee5\u7acb\u5373\u91cd\u8bd5\u3002<\/p>\n

\u7b2c\u516d\u7ec4，TSFN Queue \u4e0d\u6ea2\u51fa\u3002<\/p>\n

\u7b2c\u4e03\u7ec4，TSFN release \u4e00\u6b21，finalize \u4e00\u6b21\u3002<\/p>\n

\u7b2c\u516b\u7ec4，\u8c03\u8bd5\u591a\u7ebf\u7a0b\u68c0\u6d4b\u6ca1\u6709\u8de8\u7ebf\u7a0b NAPI \u8fdd\u89c4\u3002<\/p>\n

\u7b2c\u4e5d\u7ec4，TSan \u538b\u6d4b\u6ca1\u6709\u6570\u636e\u7ade\u4e89\u4e0e Use-After-Free\u3002<\/p>\n

\u5168\u90e8\u901a\u8fc7\u4ee5\u540e：<\/p>\n

THREADSAFE_PROGRESS_READY<\/p>\n

\u624d\u6210\u7acb\u3002<\/p>\n

\u5341\u516b\u3001\u4e0b\u4e00\u7bc7：\u529f\u80fd\u94fe\u7a33\u5b9a\u4ee5\u540e，\u5f00\u59cb\u5904\u7406\u201c\u600e\u4e48\u4ea4\u4ed8\u8fd9\u4e2a Native \u5e93\u201d<\/h3>\n

JsonPulse \u5230 04 \u5df2\u7ecf\u6709：<\/p>\n

CMake \u96c6\u6210
\nNode-API
\nTypedArray
\n\u540c\u6b65\u96f6\u590d\u5236
\nAsync Work
\nPromise
\nTSFN Progress
\nCancel \/ Retry<\/p>\n

\u4e0b\u4e00\u4e2a\u771f\u5b9e\u95ee\u9898\u4e0d\u518d\u662f\u201c\u4ee3\u7801\u600e\u4e48\u5199\u201d\u3002<\/p>\n

\u800c\u662f：<\/p>\n

\u8fd9\u4e2a simdjson + Node-API \u80fd\u4e0d\u80fd\u505a\u6210 HAR？<\/p>\n

so \u600e\u4e48\u653e？<\/p>\n

arm64-v8a \/ x86_64 \u600e\u4e48\u5904\u7406？<\/p>\n

\u7b26\u53f7\u600e\u4e48\u68c0\u67e5？<\/p>\n

\u7b2c\u4e09\u65b9 License \u600e\u4e48\u8ddf\u5305\u8d70？<\/p>\n

05 \u4f1a\u628a JsonPulse \u4ece\u201c\u5e94\u7528\u91cc\u7684 Native \u4ee3\u7801\u201d\u63a8\u8fdb\u6210\u4e00\u4e2a\u53ef\u5206\u53d1\u7684\u4e09\u65b9\u9002\u914d\u5305\u3002<\/p>\n

\u5341\u4e5d\u3001\u8fdb\u5ea6\u56de\u8c03\u7684\u6570\u636e\u7ed3\u6784\u5fc5\u987b\u662f\u201c\u53ef\u4e22\u7684\u4e2d\u95f4\u6001\u201d<\/h3>\n

TSFN \u8fdb\u5ea6\u6570\u636e\u4e0d\u5e94\u8be5\u643a\u5e26：<\/p>\n

\u5b8c\u6574 DOM
\n\u5927\u5b57\u7b26\u4e32
\n\u5927\u6570\u7ec4<\/p>\n

\u5426\u5219\u6bcf 5% \u56de\u4e00\u6b21，\u7b49\u4e8e\u4e0d\u65ad\u8de8\u7ebf\u7a0b\u642c\u5927\u5bf9\u8c61\u3002<\/p>\n

JsonPulse \u7684 ProgressEvent \u53ea\u4fdd\u7559：<\/p>\n

percent
\nprocessedBytes
\nrecordsSoFar<\/p>\n

\u51e0\u5341\u5b57\u8282\u3002<\/p>\n

\u5b83\u7684\u8bed\u4e49\u662f：<\/p>\n

UI \u53c2\u8003\u4fe1\u606f<\/p>\n

\u4e0d\u662f\u6700\u7ec8\u4e1a\u52a1\u7ed3\u679c\u3002<\/p>\n

\u6240\u4ee5\u5373\u4f7f\u4e2d\u95f4\u4e00\u4e24\u4e2a Progress \u56e0\u961f\u5217\u7b56\u7565\u88ab\u5408\u5e76，\u4e5f\u4e0d\u4f1a\u5f71\u54cd\u6700\u7ec8 ParseSummary \u7684\u6b63\u786e\u6027\u3002<\/p>\n

\u4e8c\u5341\u3001\u961f\u5217\u6ee1\u65f6\u4e0d\u80fd\u963b\u585e Worker \u53bb\u7b49 UI<\/h3>\n

napi_call_threadsafe_function \u652f\u6301 blocking \/ nonblocking \u65b9\u5f0f\u3002<\/p>\n

JsonPulse \u9009\u62e9：<\/p>\n

napi_tsfn_nonblocking<\/p>\n

\u7406\u7531\u662f\u89e3\u6790 Worker \u4e0d\u5e94\u8be5\u56e0\u4e3a UI \u6d88\u8d39 Progress \u8f83\u6162\u800c\u505c\u4f4f\u3002<\/p>\n

\u5982\u679c\u961f\u5217\u6ee1：<\/p>\n

\u5f53\u524d\u4e2d\u95f4\u8fdb\u5ea6\u53ef\u4ee5\u4e22
\n\u4e0b\u4e00\u6863\u7ee7\u7eed\u5c1d\u8bd5<\/p>\n

\u6700\u7ec8\u7ed3\u679c\u4ecd\u7136\u7531 async work \u7684 CompleteCB \u56de\u4f20\u3002<\/p>\n

\u8fd9\u5c31\u662f\u4e3a\u4ec0\u4e48：<\/p>\n

Progress
\n\u53ef\u4ee5 best-effort<\/p>\n

Final Result
\n\u5fc5\u987b reliable<\/p>\n

\u4e24\u6761\u901a\u9053\u8981\u5206\u5f00\u3002<\/p>\n

\u4e8c\u5341\u4e00\u3001\u53d6\u6d88\u8bf7\u6c42\u53ea\u6539\u539f\u5b50\u72b6\u6001，\u4e0d\u76f4\u63a5\u64cd\u4f5c Parser<\/h3>\n

ArkTS \u70b9\u51fb\u53d6\u6d88\u4ee5\u540e，Native \u63a5\u53e3\u53ea\u505a：<\/p>\n

cancelRequested.store(true)<\/p>\n

\u4e0d\u4f1a\u5728\u53e6\u4e00\u4e2a\u7ebf\u7a0b\u91cc：<\/p>\n

\u76f4\u63a5 delete parser
\n\u6e05\u7a7a buffer
\n\u91ca\u653e Context<\/p>\n

\u56e0\u4e3a Parser \u8fd8\u53ef\u80fd\u6b63\u88ab Worker \u4f7f\u7528\u3002<\/p>\n

\u771f\u6b63\u505c\u6b62\u53d1\u751f\u5728 Worker \u81ea\u5df1\u8bfb\u5230 Flag \u7684\u68c0\u67e5\u70b9\u3002<\/p>\n

\u8fd9\u79cd\u534f\u4f5c\u5f0f\u53d6\u6d88\u7684\u6838\u5fc3\u4f18\u52bf\u662f：<\/p>\n

\u91ca\u653e\u8d44\u6e90\u7684\u4eba
\n\u4ecd\u7136\u662f\u4f7f\u7528\u8d44\u6e90\u7684\u90a3\u6761\u6267\u884c\u94fe\u3002<\/p>\n

\u4e0d\u4f1a\u51fa\u73b0\u4e24\u4e2a\u7ebf\u7a0b\u4e89\u62a2 delete \u7684\u60c5\u51b5\u3002<\/p>\n

\u4e8c\u5341\u4e8c\u3001\u53d6\u6d88\u68c0\u67e5\u70b9\u592a\u5bc6\u548c\u592a\u7a00\u90fd\u4e0d\u597d<\/h3>\n

\u5982\u679c\u6bcf\u5904\u7406\u51e0\u5341\u4e2a\u5b57\u8282\u5c31：<\/p>\n

atomic.load()<\/p>\n

\u4f1a\u7ed9\u70ed\u5faa\u73af\u589e\u52a0\u989d\u5916\u6210\u672c\u3002<\/p>\n

\u5982\u679c\u53ea\u5728 50MB \u5904\u7406\u5b8c\u624d\u68c0\u67e5：<\/p>\n

\u53d6\u6d88\u51e0\u4e4e\u6ca1\u6709\u610f\u4e49\u3002<\/p>\n

JsonPulse \u5f53\u524d\u6309 chunk \u8bfb\u53d6 \/ \u7edf\u8ba1\u9636\u6bb5\u68c0\u67e5\u3002<\/p>\n

\u7b2c\u4e00\u6b21：<\/p>\n

61% request
\n62% observed
\n11.8ms<\/p>\n

\u8bf4\u660e\u53d6\u6d88\u5ef6\u8fdf\u5728\u5f53\u524d\u6d4b\u8bd5\u91cc\u53ef\u63a5\u53d7\u3002<\/p>\n

\u771f\u6b63\u4ea7\u54c1\u4ecd\u7136\u8981\u6839\u636e：<\/p>\n

chunk size
\n\u89e3\u6790\u9636\u6bb5
\nCPU \u5f00\u9500<\/p>\n

\u8c03\u6574\u68c0\u67e5\u7c92\u5ea6\u3002<\/p>\n

\u4e8c\u5341\u4e09\u3001Retry \u5fc5\u987b\u521b\u5efa\u5168\u65b0\u7684 TSFN \u4e0e Work Context<\/h3>\n

\u7b2c\u4e00\u6b21 CANCELLED \u540e，\u4e0d\u80fd：<\/p>\n

\u628a\u65e7 ctx.cancelRequested=false
\n\u7136\u540e\u91cd\u65b0 queue \u540c\u4e00\u4e2a work<\/p>\n

\u5b98\u65b9 async work \u672c\u8eab\u5efa\u8bae\u5355\u6b21\u4f7f\u7528，TSFN \u53c8\u6709\u81ea\u5df1\u7684 release\/finalize \u751f\u547d\u5468\u671f\u3002<\/p>\n

\u6240\u4ee5 Retry \u5b8c\u6574\u8d70：<\/p>\n

new Context
\nnew async work
\nnew TSFN
\nnew Native Buffer<\/p>\n

\u8fd9\u4e5f\u662f：<\/p>\n

finalizeCount=1<\/p>\n

\u4e3a\u4ec0\u4e48\u9488\u5bf9\u5355\u6b21\u4efb\u52a1\u7edf\u8ba1，\u800c\u4e0d\u662f\u6574\u4e2a\u9875\u9762\u6c38\u8fdc\u53ea\u6709\u4e00\u4e2a TSFN\u3002<\/p>\n

\u4e8c\u5341\u56db\u3001Finalize \u548c Complete \u7684\u5148\u540e\u4e0d\u80fd\u9760\u731c<\/h3>\n

\u4e0d\u540c\u8d44\u6e90\u7531\u4e0d\u540c Owner \u8d1f\u8d23\u3002<\/p>\n

JsonPulse \u7ea6\u5b9a：<\/p>\n

CompleteCB
\n\u8d1f\u8d23：
\nPromise
\nasync_work
\nNative Buffer
\nTask Context \u7684\u4e3b\u751f\u547d\u5468\u671f<\/p>\n

TSFN Finalize
\n\u8d1f\u8d23：
\nTSFN \u81ea\u5df1\u5173\u8054\u7684\u8f7b\u91cf\u4e0a\u4e0b\u6587<\/p>\n

\u4e24\u8005\u4e0d\u80fd\u540c\u65f6：<\/p>\n

delete ProgressContext<\/p>\n

\u5426\u5219\u5148\u540e\u987a\u5e8f\u53d8\u5316\u65f6\u5c31\u4f1a double free\u3002<\/p>\n

04 \u7684 double free=0 \u4e0d\u662f\u9760\u8fd0\u6c14，\u800c\u662f\u56e0\u4e3a\u8d44\u6e90\u62c6\u4e86 Owner\u3002<\/p>\n

\u4e8c\u5341\u4e94\u3001ArkTS onProgress \u81ea\u5df1\u4e5f\u4e0d\u80fd\u505a\u91cd\u6d3b<\/h3>\n

\u5373\u4f7f Native \u4fa7\u5df2\u7ecf\u5b89\u5168\u56de\u5230 ArkTS \u7ebf\u7a0b，\u5982\u679c：<\/p>\n

onProgress<\/span> =<\/span> (<\/span>)<\/span> =><\/span> {<\/span>
\n \u5927\u91cf JSON<\/span> stringify
\n \u540c\u6b65\u6570\u636e\u5e93\u5199\u5165
\n \u590d\u6742\u5217\u8868\u91cd\u5efa
\n}<\/span><\/p>\n

\u4ecd\u7136\u4f1a\u628a UI \u5361\u4f4f\u3002<\/p>\n

\u6240\u4ee5 JsonPulse \u7684 onProgress \u53ea\u505a：<\/p>\n

\u66f4\u65b0\u767e\u5206\u6bd4
\n\u66f4\u65b0\u5df2\u5904\u7406\u8bb0\u5f55\u6570
\n\u5c11\u91cf\u72b6\u6001<\/p>\n

\u771f\u6b63\u65e5\u5fd7\u6301\u4e45\u5316\u653e\u5230\u4f4e\u9891\u91c7\u6837\u6216\u4efb\u52a1\u7ed3\u675f\u4ee5\u540e\u3002<\/p>\n

TSFN \u89e3\u51b3\u7684\u662f\u7ebf\u7a0b\u5b89\u5168，\u4e0d\u662f\u81ea\u52a8\u89e3\u51b3 UI \u56de\u8c03\u6027\u80fd\u3002<\/p>\n

\u4e8c\u5341\u516d\u3001Progress Callback \u4e5f\u8981\u6709\u9875\u9762\u4ee3\u9645\u68c0\u67e5<\/h3>\n

03 \u5df2\u7ecf\u7ed9 Promise Result \u589e\u52a0\u9875\u9762 generation\u3002<\/p>\n

04 \u7684\u4e2d\u95f4 Progress \u540c\u6837\u9700\u8981\u3002<\/p>\n

\u5982\u679c\u7528\u6237\u79bb\u5f00\u9875\u9762：<\/p>\n

Worker \u8fd8\u5728
\nProgress \u8fd8\u5728\u6295\u9012<\/p>\n

\u65e7\u9875\u9762\u4e0d\u80fd\u7ee7\u7eed\u66f4\u65b0\u3002<\/p>\n

\u6240\u4ee5 ArkTS \u7684 onProgress \u7b2c\u4e00\u884c\u5148\u5224\u65ad：<\/p>\n

task generation
\n\u662f\u5426\u4ecd\u7136 active<\/p>\n

\u5931\u6548\u5c31\u76f4\u63a5 return\u3002<\/p>\n

Native \u4efb\u52a1\u53ef\u4ee5\u7ee7\u7eed\u6536\u53e3，UI \u4e0d\u518d\u54cd\u5e94\u3002<\/p>\n

\u8fd9\u6837\u4e0d\u4f1a\u56e0\u4e3a\u4e00\u4e2a\u5df2\u7ecf\u79bb\u5f00\u7684\u9875\u9762\u8fd8\u6536\u5230 70%\u300175%\u300180% \u7684\u8fdb\u5ea6\u800c\u51fa\u73b0\u72b6\u6001\u5f02\u5e38\u3002<\/p>\n

\u4e8c\u5341\u4e03\u3001ThreadSafeFunction \u7684 Queue \u5927\u5c0f\u5e94\u8be5\u6765\u6e90\u4e8e\u56de\u8c03\u9891\u7387<\/h3>\n

\u672c\u8f6e：<\/p>\n

progressStep=5%
\nmaxQueue=8<\/p>\n

20 \u6b21\u56de\u8c03\u3002<\/p>\n

\u5982\u679c\u672a\u6765：<\/p>\n

1% \u4e00\u6b21<\/p>\n

\u5c31\u53ef\u80fd\u9700\u8981：<\/p>\n

100 \u6b21\u56de\u8c03<\/p>\n

\u961f\u5217\u538b\u529b\u5b8c\u5168\u4e0d\u540c\u3002<\/p>\n

\u6240\u4ee5 max_queue_size=8 \u4e0d\u662f JsonPulse \u7684\u6c38\u6052\u503c\u3002<\/p>\n

\u66f4\u5408\u7406\u7684\u7b56\u7565\u662f：<\/p>\n

\u56de\u8c03\u9891\u7387\u8d8a\u9ad8
\n\u2192 \u66f4\u79ef\u6781\u5408\u5e76
\n\u800c\u4e0d\u662f\u76f2\u76ee\u628a queue \u5f00\u5230 1024<\/p>\n

\u56e0\u4e3a\u5927 Queue \u53ea\u4f1a\u628a\u201c\u5b9e\u65f6\u8fdb\u5ea6\u201d\u53d8\u6210\u201c\u6392\u961f\u5f88\u4e45\u4ee5\u540e\u624d\u5230\u7684\u65e7\u8fdb\u5ea6\u201d\u3002<\/p>\n

\u4e8c\u5341\u516b\u3001\u53d6\u6d88\u540e\u7684 UI \u72b6\u6001\u4e5f\u8981\u533a\u5206 CANCELLED \u548c FAILED<\/h3>\n

\u7528\u6237\u4e3b\u52a8\u53d6\u6d88：<\/p>\n

CANCELLED<\/p>\n

\u4e0d\u662f：<\/p>\n

FAILED<\/p>\n

\u8fd9\u4e24\u79cd\u72b6\u6001\u4f1a\u5f71\u54cd\u540e\u7eed\u4ea7\u54c1\u884c\u4e3a\u3002<\/p>\n

CANCELLED：<\/p>\n

\u5141\u8bb8\u7acb\u5373\u91cd\u8bd5
\n\u4e0d\u663e\u793a\u9519\u8bef\u7ea2\u6846
\n\u4fdd\u7559\u6e90\u6587\u4ef6<\/p>\n

FAILED：<\/p>\n

\u663e\u793a errorCode
\n\u53ef\u80fd\u8981\u6c42\u66f4\u6362\u8f93\u5165<\/p>\n

\u672c\u8f6e\u7b2c\u4e00\u6b21\u72b6\u6001\u660e\u786e：<\/p>\n

firstRunStatus=CANCELLED<\/p>\n

\u7b2c\u4e8c\u6b21 Retry：<\/p>\n

PASS<\/p>\n

\u72b6\u6001\u673a\u6bd4\u4e00\u4e2a boolean success \u66f4\u80fd\u652f\u6491\u771f\u5b9e\u4ea7\u54c1\u3002<\/p>\n

\u4e8c\u5341\u4e5d\u3001\u8de8\u7ebf\u7a0b\u9519\u8bef\u68c0\u6d4b\u8981\u5728 Debug \/ Test \u6784\u5efa\u91cc\u5e38\u6001\u5316<\/h3>\n

HarmonyOS 2026 \u7684 Node-API \u5d29\u6e83\u5206\u6790\u6587\u6863\u5df2\u7ecf\u9488\u5bf9：<\/p>\n

env owner \u4e0d\u4e00\u81f4
\ndead env
\n\u8de8\u7ebf\u7a0b NAPI
\nTSFN \u9519\u8bef\u8c03\u7528<\/p>\n

\u63d0\u4f9b\u66f4\u660e\u786e\u7684\u8bca\u65ad\u3002<\/p>\n

JsonPulse \u4e0d\u4f1a\u53ea\u5728\u201c\u5d29\u4e86\u4ee5\u540e\u201d\u6253\u5f00\u8fd9\u4e9b\u624b\u6bb5\u3002<\/p>\n

04 \u7684\u6d4b\u8bd5\u6784\u5efa\u628a：<\/p>\n

\u591a\u7ebf\u7a0b\u68c0\u6d4b
\nTSan
\nNative \u65e5\u5fd7<\/p>\n

\u4f5c\u4e3a\u5e38\u89c4\u9a8c\u6536\u5de5\u5177\u3002<\/p>\n

Release \u5173\u95ed\u9ad8\u5f00\u9500\u5de5\u5177，Debug \/ CI \u4fdd\u7559\u7ebf\u7a0b\u6b63\u786e\u6027\u95e8\u7981\u3002<\/p>\n

\u4e09\u5341\u3001THREADSAFE_PROGRESS_READY \u7684\u5b8c\u6574\u542b\u4e49<\/h3>\n

\u6700\u7ec8\u72b6\u6001\u81f3\u5c11\u4ee3\u8868：<\/p>\n

TSFN \u5728\u6b63\u786e env \u521b\u5efa；<\/p>\n

Worker \u53ea\u8c03\u7528\u7ebf\u7a0b\u5b89\u5168\u63a5\u53e3；<\/p>\n

20 \u6b21\u8fdb\u5ea6\u6709\u5e8f\u56de\u5230 ArkTS；<\/p>\n

\u961f\u5217\u6ca1\u6709\u6ea2\u51fa；<\/p>\n

61% \u53d6\u6d88\u5728 62% \u89c2\u5bdf\u5230；<\/p>\n

\u53d6\u6d88\u4e0d\u8df3\u8fc7 CompleteCB；<\/p>\n

\u53d6\u6d88\u540e\u53ef\u5e72\u51c0 Retry；<\/p>\n

Retry \u5b8c\u6574\u89e3\u6790 496,000 \u6761\u8bb0\u5f55；<\/p>\n

TSFN release \u4e00\u6b21；<\/p>\n

Finalize \u4e00\u6b21；<\/p>\n

\u6ca1\u6709\u8de8\u7ebf\u7a0b NAPI \u8fdd\u89c4；<\/p>\n

\u6ca1\u6709\u5df2\u77e5\u6570\u636e\u7ade\u4e89\u3002<\/p>\n

\u505a\u5230\u8fd9\u91cc\u4ee5\u540e，JsonPulse \u7684 Native \u5f02\u6b65\u670d\u52a1\u624d\u771f\u6b63\u5177\u5907\u201c\u8fdb\u5ea6\u53ef\u89c1\u3001\u4efb\u52a1\u53ef\u63a7\u3001\u7ebf\u7a0b\u53ef\u89e3\u91ca\u201d\u7684\u5de5\u7a0b\u5f62\u6001\u3002<\/p>\n

\u4e09\u5341\u4e00\u3001\u8fdb\u5ea6\u503c\u672c\u8eab\u4e0d\u80fd\u5f53\u6210\u53d6\u6d88\u68c0\u67e5\u70b9\u7684\u552f\u4e00\u4f9d\u636e<\/h3>\n

\u672c\u8f6e\u7528 61% \u8bf7\u6c42\u300162% \u751f\u6548\u6765\u5c55\u793a\u53d6\u6d88\u94fe，\u4f46 Worker \u5185\u90e8\u771f\u6b63\u68c0\u67e5\u7684\u662f chunk \u8fb9\u754c，\u800c\u4e0d\u662f\u201c\u767e\u5206\u6bd4\u7b49\u4e8e 62 \u65f6\u9000\u51fa\u201d\u3002\u767e\u5206\u6bd4\u53ea\u662f\u6839\u636e\u5df2\u5904\u7406\u5b57\u8282\u63a8\u5bfc\u51fa\u7684 UI \u6307\u6807\u3002\u8fd9\u6837\u5373\u4f7f\u4e0d\u540c\u6570\u636e\u96c6\u6bcf\u4e2a chunk \u7684\u8bb0\u5f55\u5bc6\u5ea6\u5dee\u5f02\u5f88\u5927，\u53d6\u6d88\u673a\u5236\u4ecd\u7136\u57fa\u4e8e\u7a33\u5b9a\u7684 Native \u5904\u7406\u8fb9\u754c，\u800c\u4e0d\u662f\u4f9d\u8d56\u67d0\u4e2a\u89c6\u89c9\u8fdb\u5ea6\u6570\u503c\u3002<\/p>\n

\u4e09\u5341\u4e8c\u3001TSFN \u56de\u8c03\u8981\u9632\u6b62\u201c\u4efb\u52a1\u5df2\u7ecf\u6362\u4ee3，\u65e7\u8fdb\u5ea6\u8fd8\u5728\u961f\u5217\u91cc\u201d<\/h3>\n

\u5373\u4f7f Worker \u5df2\u7ecf\u7ed3\u675f，\u4e8b\u4ef6\u5faa\u73af\u91cc\u4e5f\u53ef\u80fd\u8fd8\u6709\u5c1a\u672a\u6d88\u8d39\u7684\u65e7 Progress\u3002JsonPulse \u7684\u6bcf\u4e2a ProgressEvent \u90fd\u5e26 taskId \u548c generation\u3002ArkTS \u6536\u5230\u540e\u5982\u679c\u53d1\u73b0\u9875\u9762\u5df2\u7ecf\u542f\u52a8\u4e0b\u4e00\u6b21 Retry，\u5c31\u4e22\u5f03\u65e7 generation \u7684\u8fdb\u5ea6，\u4e0d\u8ba9\u7b2c\u4e00\u6b21 CANCELLED \u4efb\u52a1\u7684 60% \u72b6\u6001\u8986\u76d6\u7b2c\u4e8c\u6b21 Retry \u7684 15%\u3002\u8fd9\u6761\u4ee3\u9645\u4fdd\u62a4\u4e0e 03 \u7684 Promise generation \u662f\u540c\u4e00\u5957\u8bbe\u8ba1\u3002<\/p>\n

\u4e09\u5341\u4e09\u3001\u53d6\u6d88\u91cd\u8bd5\u4e4b\u540e\u8fd8\u8981\u68c0\u67e5\u65e7 TSFN \u5df2\u7ecf\u5b8c\u5168\u9000\u51fa<\/h3>\n

Retry \u65b0\u5efa TSFN \u4e4b\u524d，\u9879\u76ee\u4f1a\u786e\u8ba4\u65e7\u4efb\u52a1\u5df2\u7ecf\u8d70\u5b8c release\/finalize，\u4e0d\u4f1a\u8ba9\u4e24\u5957 ThreadSafeFunction \u540c\u65f6\u5411\u540c\u4e00\u4e2a\u9875\u9762\u56de\u8c03\u3002\u8fd9\u6837\u53ef\u4ee5\u9632\u6b62\u201c\u53d6\u6d88\u540e\u9a6c\u4e0a\u91cd\u8bd5\u201d\u65f6\u51fa\u73b0\u4e24\u6761\u8fdb\u5ea6\u66f2\u7ebf\u4e92\u76f8\u8986\u76d6\u3002\u6700\u7ec8 finalizeCount=1\u3001crossThreadNapiViolations=0 \u53ea\u662f\u5355\u6b21\u4efb\u52a1\u6307\u6807；\u5b8c\u6574\u538b\u529b\u6d4b\u8bd5\u8fd8\u8981\u786e\u4fdd\u6bcf\u6b21 Retry \u90fd\u80fd\u5f62\u6210\u4e25\u683c\u7684\u4e00\u8fdb\u4e00\u51fa\u751f\u547d\u5468\u671f\u3002<\/p>\n

\u53c2\u8003\u8d44\u6599<\/h3>\n