bq_react/doc/项目文档/基础应用/线程脚本(WebWorker).md

线程脚本

目录

• 功能定义
• 使用示例
• 时序
  • 请求与回复

功能定义

线程脚本管理一个 Worker 的创建、请求和崩溃。当前没有功能模块调用它。

入口	文件	定义
WorkerSession.request(message)	src/app/worker/worker_session.ts	保证 Worker 存在，发送 WorkerMessage，并等待对应 WorkerReply
WorkerSession.dispose()	同上	拒绝尚未完成的请求，并终止 Worker
WorkerRuntime.listen(handlers)	src/app/worker/worker_runtime.ts	在 Worker 线程按 type 分发，并用 WorkerReply 回复
WorkerMessage	src/app/worker/entities/worker_message.ts	请求体。含 id、type、payload
WorkerReply	src/app/worker/entities/worker_reply.ts	回复体。按 id 交回等待中的请求
WorkerError	src/app/worker/entities/worker_error.ts	Worker 失败时的错误

连续崩溃超过一次后，WorkerSession 停止再创建，后续 request 直接拒绝。

使用示例

调用方传入创建函数，再发送一条消息。

const worker = new WorkerSession(() => new Worker('worker.js'));
const message = new WorkerMessage('type', payload);
const result = await worker.request(message);

时序

请求与回复

sequenceDiagram
  participant WorkerSession
  participant WorkerMessage
  participant WorkerReply

  WorkerSession->>WorkerSession: ensure()
  WorkerSession->>WorkerMessage: toJson()
  WorkerSession->>WorkerReply: fromJson(data)
  WorkerReply-->>WorkerSession: unwrap()

ensure 没有实例时调用构造函数传入的工厂。request 按 WorkerMessage.id 登记等待。Worker 线程里的 WorkerRuntime.listen 按 type 调用处理函数，并用 WorkerReply 回复。onmessage 用 WorkerReply.fromJson 找到同一 id，再 unwrap 完成该请求。onerror 或 onmessageerror 时终止当前 Worker，并拒绝尚未完成的请求。