foster/denoland-deno
1
0
Fork 0
mirror of https://github.com/denoland/deno.git synced 2025-01-03 04:48:52 -05:00
Code Issues Packages 1 Wiki Activity

refactor(ext/node): remove worker_threads dependency on ext:runtime (#23206)

Browse source
This commit is contained in:
Satya Rohith 2024-04-04 01:09:53 +05:30 committed by GitHub
parent 778b0b8eb5
commit aa08155fd1
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 9 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
ext/node/polyfills/worker_threads.ts
View file

@ -21,7 +21,6 @@ import {
serializeJsMessageData, serializeJsMessageData,
} from "ext:deno_web/13_message_port.js"; } from "ext:deno_web/13_message_port.js";
import * as webidl from "ext:deno_webidl/00_webidl.js"; import * as webidl from "ext:deno_webidl/00_webidl.js";
import { log } from "ext:runtime/06_util.js";
import { notImplemented } from "ext:deno_node/_utils.ts"; import { notImplemented } from "ext:deno_node/_utils.ts";
import { EventEmitter } from "node:events"; import { EventEmitter } from "node:events";
import { BroadcastChannel } from "ext:deno_broadcast_channel/01_broadcast_channel.js"; import { BroadcastChannel } from "ext:deno_broadcast_channel/01_broadcast_channel.js";
@ -38,6 +37,14 @@ const {
TypeError, TypeError,
} = primordials; } = primordials;
const debugWorkerThreads = false;
function debugWT(...args) {
if (debugWorkerThreads) {
// deno-lint-ignore prefer-primordials
console.log(...args);
}
}
export interface WorkerOptions { export interface WorkerOptions {
// only for typings // only for typings
argv?: unknown[]; argv?: unknown[];
@ -190,7 +197,7 @@ class NodeWorker extends EventEmitter {
break; break;
} }
case 3: { // Close case 3: { // Close
log(`Host got "close" message from worker: ${this.#name}`); debugWT(`Host got "close" message from worker: ${this.#name}`);
this.#status = "CLOSED"; this.#status = "CLOSED";
return; return;
} }