deno.land / x / deno@v1.28.2 / runtime / js / 11_workers.js
نووسراو ببینە
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255// Copyright 2018-2022 the Deno authors. All rights reserved. MIT license."use strict";
((window) => { const core = window.Deno.core; const ops = core.ops; const { Error, ObjectPrototypeIsPrototypeOf, StringPrototypeStartsWith, String, SymbolIterator, SymbolToStringTag, } = window.__bootstrap.primordials; const webidl = window.__bootstrap.webidl; const { URL } = window.__bootstrap.url; const { getLocationHref } = window.__bootstrap.location; const { serializePermissions } = window.__bootstrap.permissions; const { log } = window.__bootstrap.util; const { ErrorEvent, MessageEvent, defineEventHandler } = window.__bootstrap.event; const { EventTarget } = window.__bootstrap.eventTarget; const { deserializeJsMessageData, serializeJsMessageData, MessagePortPrototype, } = window.__bootstrap.messagePort;
function createWorker( specifier, hasSourceCode, sourceCode, permissions, name, workerType, ) { return ops.op_create_worker({ hasSourceCode, name, permissions: serializePermissions(permissions), sourceCode, specifier, workerType, }); }
function hostTerminateWorker(id) { ops.op_host_terminate_worker(id); }
function hostPostMessage(id, data) { ops.op_host_post_message(id, data); }
function hostRecvCtrl(id) { return core.opAsync("op_host_recv_ctrl", id); }
function hostRecvMessage(id) { return core.opAsync("op_host_recv_message", id); }
class Worker extends EventTarget { #id = 0; #name = "";
// "RUNNING" | "CLOSED" | "TERMINATED" // "TERMINATED" means that any controls or messages received will be // discarded. "CLOSED" means that we have received a control // indicating that the worker is no longer running, but there might // still be messages left to receive. #status = "RUNNING";
constructor(specifier, options = {}) { super(); specifier = String(specifier); const { deno, name, type = "classic", } = options;
const workerType = webidl.converters["WorkerType"](type);
if ( StringPrototypeStartsWith(specifier, "./") || StringPrototypeStartsWith(specifier, "../") || StringPrototypeStartsWith(specifier, "/") || workerType === "classic" ) { const baseUrl = getLocationHref(); if (baseUrl != null) { specifier = new URL(specifier, baseUrl).href; } }
this.#name = name; let hasSourceCode, sourceCode; if (workerType === "classic") { hasSourceCode = true; sourceCode = `importScripts("#");`; } else { hasSourceCode = false; sourceCode = ""; }
const id = createWorker( specifier, hasSourceCode, sourceCode, deno?.permissions, name, workerType, ); this.#id = id; this.#pollControl(); this.#pollMessages(); }
#handleError(e) { const event = new ErrorEvent("error", { cancelable: true, message: e.message, lineno: e.lineNumber ? e.lineNumber : undefined, colno: e.columnNumber ? e.columnNumber : undefined, filename: e.fileName, error: null, });
this.dispatchEvent(event); // Don't bubble error event to window for loader errors (`!e.fileName`). // TODO(nayeemrmn): It's not correct to use `e.fileName` to detect user // errors. It won't be there for non-awaited async ops for example. if (e.fileName && !event.defaultPrevented) { window.dispatchEvent(event); }
return event.defaultPrevented; }
#pollControl = async () => { while (this.#status === "RUNNING") { const [type, data] = await hostRecvCtrl(this.#id);
// If terminate was called then we ignore all messages if (this.#status === "TERMINATED") { return; }
switch (type) { case 1: { // TerminalError this.#status = "CLOSED"; } /* falls through */ case 2: { // Error if (!this.#handleError(data)) { throw new Error("Unhandled error in child worker."); } break; } case 3: { // Close log(`Host got "close" message from worker: ${this.#name}`); this.#status = "CLOSED"; return; } default: { throw new Error(`Unknown worker event: "${type}"`); } } } };
#pollMessages = async () => { while (this.#status !== "TERMINATED") { const data = await hostRecvMessage(this.#id); if (this.#status === "TERMINATED" || data === null) { return; } let message, transferables; try { const v = deserializeJsMessageData(data); message = v[0]; transferables = v[1]; } catch (err) { const event = new MessageEvent("messageerror", { cancelable: false, data: err, }); this.dispatchEvent(event); return; } const event = new MessageEvent("message", { cancelable: false, data: message, ports: transferables.filter((t) => ObjectPrototypeIsPrototypeOf(MessagePortPrototype, t) ), }); this.dispatchEvent(event); } };
postMessage(message, transferOrOptions = {}) { const prefix = "Failed to execute 'postMessage' on 'MessagePort'"; webidl.requiredArguments(arguments.length, 1, { prefix }); message = webidl.converters.any(message); let options; if ( webidl.type(transferOrOptions) === "Object" && transferOrOptions !== undefined && transferOrOptions[SymbolIterator] !== undefined ) { const transfer = webidl.converters["sequence<object>"]( transferOrOptions, { prefix, context: "Argument 2" }, ); options = { transfer }; } else { options = webidl.converters.StructuredSerializeOptions( transferOrOptions, { prefix, context: "Argument 2", }, ); } const { transfer } = options; const data = serializeJsMessageData(message, transfer); if (this.#status === "RUNNING") { hostPostMessage(this.#id, data); } }
terminate() { if (this.#status !== "TERMINATED") { this.#status = "TERMINATED"; hostTerminateWorker(this.#id); } }
[SymbolToStringTag] = "Worker"; }
defineEventHandler(Worker.prototype, "error"); defineEventHandler(Worker.prototype, "message"); defineEventHandler(Worker.prototype, "messageerror");
webidl.converters["WorkerType"] = webidl.createEnumConverter("WorkerType", [ "classic", "module", ]);
window.__bootstrap.worker = { Worker, };})(this);
deno
Version Info
a year ago
