byp4a55 professor6T9

Linux SamCT211 4.4.302+ #86009 SMP Wed Nov 26 18:19:20 CST 2025 x86_64
nginx/1.23.1
192.168.4.211

File Name : task.js

"use strict";
Object.defineProperty(exports, "__esModule", {
    value: true
});
Object.defineProperty(exports, "ThreadWorkerTask", {
    enumerable: true,
    get: function() {
        return ThreadWorkerTask;
    }
});
const _define = require("./define");
class ThreadWorkerTask {
    constructor(worker, request, config = Object.create(null)){
        this.worker = worker;
        const { timeout, timeoutKill } = config;
        this.timeout = timeout ?? 3600000; // 1hr
        this.timeoutKill = timeoutKill ?? true;
        this.timer = null;
        this.request = request;
        this.promise = undefined;
        this._resolve = undefined;
        this._reject = undefined;
    }
    /**
   * Execute this task and return a promise containing the result. Note that
   * repeatedly execution would return the same result promise as the first
   * execution.
   */ execute() {
        if (this.promise) {
            return this.promise;
        }
        // Consume request.
        const request = this.request;
        this.request = undefined;
        const promise = request ? this.doExecute(request) : Promise.reject(_define.WorkerErrorEnum.TASK_INVALID);
        return this.promise = promise;
    }
    /**
   * Send the request to worker return a promise containing the result.
   */ doExecute(request) {
        return new Promise((resolve, reject)=>{
            this._resolve = resolve;
            this._reject = reject;
            this.worker.postMessage(request);
            // Only set timeout when it is not 0.
            if (this.timeout) {
                this.timer = setTimeout(()=>{
                    this.reject(_define.WorkerErrorEnum.TASK_TIMEOUT);
                    if (this.timeoutKill) {
                        this.worker.terminate();
                    }
                }, this.timeout);
            }
        });
    }
    reset() {
        // Clear promise.
        this._resolve = undefined;
        this._reject = undefined;
        // Clear timeout.
        if (this.timer != null) {
            clearTimeout(this.timer);
            this.timer = null;
        }
    }
    resolve(response) {
        if (!this._resolve) {
            return;
        }
        this._resolve(response);
        this.reset();
    }
    reject(reason) {
        if (!this._reject) {
            return;
        }
        this._reject(reason);
        this.reset();
    }
}

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	198276/198276	0755	2026-04-17 03:25:13
..	dir	-	198276/198276	0755	2026-04-17 03:25:12
define.js	text/plain	717 B	198276/198276	0644	2026-04-17 03:23:36
index.js	text/plain	631 B	198276/198276	0644	2026-04-17 03:23:36
manager.js	text/x-c++	3.28 KB	198276/198276	0644	2026-04-17 03:23:36
task.js	text/x-c++	2.35 KB	198276/198276	0644	2026-04-17 03:23:36
worker.js	text/x-c++	3.52 KB	198276/198276	0644	2026-04-17 03:23:36

Team Anon Force

https://t.me/Professor6T9x