diff --git a/@sammo/server/src/worker_test.ts b/@sammo/server/src/worker_test.ts index 1589dcd..57e1ad9 100644 --- a/@sammo/server/src/worker_test.ts +++ b/@sammo/server/src/worker_test.ts @@ -1,16 +1,14 @@ -import { Worker, parentPort, MessageChannel } from "node:worker_threads"; +import { Worker, MessageChannel } from "node:worker_threads"; import * as nodePath from "node:path"; +import { fileURLToPath } from "node:url"; console.log("Hello from worker_test.ts!"); -const __filename = new URL(import.meta.url).pathname; +const __filename = fileURLToPath(new URL(import.meta.url)); const __dirname = nodePath.dirname(__filename); const worker_b_ts = nodePath.join(__dirname, "worker_b.ts"); const worker_a_ts = nodePath.join(__dirname, "worker_a.ts"); - - - const worker_b = new Worker(worker_b_ts); const worker_a = new Worker(worker_a_ts); diff --git a/@sammo/util/src/index.ts b/@sammo/util/src/index.ts index d1109c0..6c23dc5 100644 --- a/@sammo/util/src/index.ts +++ b/@sammo/util/src/index.ts @@ -20,6 +20,9 @@ export function calcBase64Len(length: number) { export function delay(time: number): Promise; export function delay(time: number, result: T): Promise; export function delay(time: number, result?: T): Promise { + if(time <= 0){ + return new Promise(r => r(result)); + } return new Promise(resolve => setTimeout(() => { resolve(result);