gnh1201/welsonjs
1
0
Fork 0
mirror of https://github.com/gnh1201/welsonjs.git synced 2025-05-08 20:56:04 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Update task.js

Browse Source
This commit is contained in:
Namhyeon Go 2022-09-22 15:57:14 +09:00 committed by GitHub
parent c5d90ad65d
commit 63a0f3c492
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 17 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
lib/task.js
View File

@ -16,7 +16,7 @@
* // taskQueue.run(); * // taskQueue.run();
*/ */
var Task = function(f, params) { function Task(f, params) {
this.f = f; this.f = f;
this.params = params; this.params = params;
this.nextTask = null; this.nextTask = null;
@ -51,7 +51,7 @@ var Task = function(f, params) {
}; };
}; };
var TaskQueue = function() { function TaskQueue() {
this._task = null; this._task = null;
this._keepalive = true; this._keepalive = true;
this.queue = []; this.queue = [];
@ -148,11 +148,11 @@ var TaskQueue = function() {
}; };
}; };
exports.createTaskQueue = function() { function createTaskQueue() {
return new TaskQueue(); return new TaskQueue();
}; };
exports.createTask = function(f, params, failTask) { function createTask(f, params, failTask) {
try { try {
return (new Task(f, params)).setFailTask(failTask); return (new Task(f, params)).setFailTask(failTask);
} catch(e) { } catch(e) {
@ -160,7 +160,7 @@ exports.createTask = function(f, params, failTask) {
} }
}; };
exports.putTask = function(q, task, delay) { function putTask = function(q, task, delay) {
try { try {
if (q instanceof TaskQueue && task instanceof Task) { if (q instanceof TaskQueue && task instanceof Task) {
return q.put(task, delay); return q.put(task, delay);
@ -170,7 +170,7 @@ exports.putTask = function(q, task, delay) {
} }
}; };
exports.nextTask = function(q) { function nextTask = function(q) {
try { try {
return q.next(); return q.next();
} catch(e) { } catch(e) {
@ -178,11 +178,11 @@ exports.nextTask = function(q) {
} }
}; };
exports.run = function(q) { function run = function(q) {
q.run(); q.run();
}; };
exports.stop = function(q) { function stop = function(q) {
q.stop(); q.stop();
}; };
@ -235,6 +235,7 @@ exports.__taskQueue__ = __taskQueue__;
exports.setTimeout = setTimeout; exports.setTimeout = setTimeout;
exports.setInterval = setInterval; exports.setInterval = setInterval;
exports.Promise = Promise; exports.Promise = Promise;
//////////////////////////////////////////////////// ////////////////////////////////////////////////////
// END Global functions // END Global functions
//////////////////////////////////////////////////// ////////////////////////////////////////////////////
@ -242,6 +243,13 @@ exports.Promise = Promise;
exports.Task = Task; exports.Task = Task;
exports.TaskQueue = TaskQueue; exports.TaskQueue = TaskQueue;
exports.VERSIONINFO = "Task Module (task.js) version 0.2"; exports.createTaskQueue = createTaskQueue;
exports.createTask = createTask;
exports.putTask = putTask;
exports.nextTask = nextTask;
exports.run = run;
exports.stop = stop;
exports.VERSIONINFO = "Task Module (task.js) version 0.2.1";
exports.global = global; exports.global = global;
exports.require = require; exports.require = require;