delay 0
This commit is contained in:
@@ -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);
|
||||
|
||||
|
||||
@@ -20,6 +20,9 @@ export function calcBase64Len(length: number) {
|
||||
export function delay(time: number): Promise<void>;
|
||||
export function delay<T>(time: number, result: T): Promise<T>;
|
||||
export function delay<T = undefined>(time: number, result?: T): Promise<T | void> {
|
||||
if(time <= 0){
|
||||
return new Promise(r => r(result));
|
||||
}
|
||||
return new Promise(resolve =>
|
||||
setTimeout(() => {
|
||||
resolve(result);
|
||||
|
||||
Reference in New Issue
Block a user