task controller 0.0.2

Author: poi5305

libs/TaskController-0.0.2.js

@@ -0,0 +1,131 @@
+function TaskController() {
+  this.tasks = {};
+  this.isRunning = false;
+  this.interval = 50;
+};
+
+TaskController.prototype.getFirstPriorityTaskName = function() {
+  var pTask = null;
+  var priority = 100;
+  var now = Date.now();
+  for (var name in this.tasks) {
+    var task = this.tasks[name];
+    if (now - task.lastRunTime < task.interval) {
+      continue;
+    }
+    if (pTask === null) {
+      pTask = task;
+      continue;
+    }
+    if (task.wait < pTask.wait) {
+      pTask = task;
+      continue;
+    }
+    if (task.interval > pTask.interval) {
+      pTask = task;
+      continue;
+    }
+    if (task.lastRunTime < pTask.lastRunTime) {
+      pTask = task;
+      continue;
+    }
+  }
+  if (pTask === null) {
+    return '';
+  }
+  pTask.wait += pTask.priority;
+  return pTask.name;
+}
+
+TaskController.prototype.loop = function () {
+  console.log('loop start');
+  while(this.isRunning) {
+    var taskName = this.getFirstPriorityTaskName();
+    var task = this.tasks[taskName];
+    if (task !== undefined) {
+      task.run();
+      task.lastRunTime = Date.now();
+      task.runTimes--;
+      if (task.runTimes === 0) {
+        delete this.tasks[taskName];
+      }
+    }
+    sleep(this.interval);
+  }
+  this.isRunning = false;
+  console.log('loop stop');
+}
+
+TaskController.prototype.updateRunInterval = function(interval) {
+  if(interval < this.interval && interval >= 50) {
+    // min interval = 50
+    this.interval = interval;
+  }
+}
+
+TaskController.prototype.newTaskObject = function (name, func, interval, runTimes, priority) {
+  var task = {
+    name: name,
+    run: func,
+    interval: interval || 1000, // 1 second
+    runTimes: runTimes || 0, // <= 0 unlimit
+    priority: priority, // same as linux, user can not controll this
+    wait: 0, // when to run, releate to priority
+    lastRunTime: 0, // last run time in millis
+  };
+  return task;
+}
+
+TaskController.prototype.newTask = function (name, func, interval, runTimes, nextRun, priority = 5) {
+  if (nextRun === undefined) {
+    nextRun = false;
+  }
+  if (typeof func !== 'function') {
+    console.log('Error not a function', name, func);
+    return;
+  }
+  var newTask = this.newTaskObject(name, func, interval, runTimes, priority);
+  if (nextRun) {
+    newTask.lastRunTime = Date.now();
+  }
+  this.updateRunInterval(newTask.interval);
+
+  var taskName = 'system_newTask_' + name;
+  var sysTask = this.newTaskObject(taskName, function() {  
+    this.tasks[name] = newTask;
+  }.bind(this), 0, 1, 1);
+  this.tasks[taskName] = sysTask;
+  return newTask;
+};
+
+TaskController.prototype.removeTask = function (name) {
+  var taskName = 'system_removeTask_' + Date.now().toString();
+  var sysTask = this.newTaskObject(taskName, function() {
+    delete this.tasks[name];
+  }.bind(this), 0, 1, 1);
+  this.tasks[taskName] = sysTask;
+}
+
+TaskController.prototype.removeAllTasks = function() {
+  var taskName = 'system_removeAllTask_' + Date.now().toString();
+  var sysTask = this.newTaskObject(taskName, function() {
+    for(var k in this.tasks) {
+      delete this.tasks[k];
+    }
+  }.bind(this), 0, 1, 1);
+  this.tasks[taskName] = sysTask;
+}
+
+TaskController.prototype.start = function () {
+  if (!this.isRunning) {
+    this.isRunning = true;
+    this.loop();
+  }
+}
+
+TaskController.prototype.stop = function () {
+  if (this.isRunning) {
+    this.isRunning = false;
+    console.log('wait loop stop...');
+  }
+}