Renamed TaskQueue to Scheduler

Author: bryanjos

src/processes/process.js

@@ -44,7 +44,7 @@ class Process {
     const function_scope = this;
     let machine = this.main();
 
-    this.system.queue(function() {
+    this.system.schedule(function() {
       function_scope.system.set_current(function_scope.pid); 
       function_scope.run(machine, machine.next()); 
     }, this.pid);  
@@ -112,7 +112,7 @@ class Process {
 
         let result = value[3]();
 
-        this.system.queue(function() { 
+        this.system.schedule(function() { 
           function_scope.system.set_current(function_scope.pid); 
           function_scope.run(machine, machine.next(result)); 
         });
@@ -127,14 +127,14 @@ class Process {
             function_scope.run(machine, step); 
           });         
         }else{
-          this.system.queue(function() { 
+          this.system.schedule(function() { 
             function_scope.system.set_current(function_scope.pid); 
             function_scope.run(machine, machine.next(result)); 
           });          
         }
 
       }else{
-        this.system.queue(function() { 
+        this.system.schedule(function() { 
           function_scope.system.set_current(function_scope.pid); 
           function_scope.run(machine, machine.next(value)); 
         });  

src/processes/process_system.js

@@ -4,7 +4,7 @@
 import Mailbox from "./mailbox";
 import Process from "./process";
 import States from "./states";
-import TaskQueue from "./task_queue";
+import Scheduler from "./scheduler";
 
 class ProcessSystem {
 
@@ -15,9 +15,9 @@ class ProcessSystem {
     this.names = new Map();
     this.links = new Map();
 
-    const throttle = 5; //ms between queued tasks
+    const throttle = 5; //ms between scheduled tasks
     this.current_process = null;
-    this.task_queue = new TaskQueue(throttle);
+    this.scheduler = new Scheduler(throttle);
     this.suspended = new Map();
 
     let process_system_scope = this;
@@ -103,7 +103,7 @@ class ProcessSystem {
   remove_proc(pid, exitreason){
     this.pids.delete(pid);
     this.unregister(pid);
-    this.task_queue.removePid(pid);
+    this.scheduler.removePid(pid);
 
     if(this.links.get(pid)){
       for (let linkpid in this.links.get(pid).entries()) {
@@ -162,7 +162,7 @@ class ProcessSystem {
       if(this.suspended.has(pid)){
         let fun = this.suspended.get(pid);
         this.suspended.delete(pid);
-        this.queue(fun);
+        this.schedule(fun);
       }
     }
 
@@ -197,12 +197,12 @@ class ProcessSystem {
 
   delay(fun, time){
     this.current_process.status = States.SLEEPING;
-    this.task_queue.queueFuture(this.current_process.pid, time, fun);
+    this.scheduler.scheduleFuture(this.current_process.pid, time, fun);
   }
 
-  queue(fun, pid){
+  schedule(fun, pid){
     const the_pid = pid != null ? pid : this.current_process.pid;
-    this.task_queue.queue(the_pid, fun); 
+    this.scheduler.schedule(the_pid, fun); 
   }
 
   exit(one, two){

src/processes/task_queue.js src/processes/scheduler.jssrc/processes/task_queue.js renamed to src/processes/scheduler.js

@@ -1,18 +1,18 @@
 "use strict";
 
-//TaskQueue. Borrowed and modified from RxJS's Default Scheduler.
+//Scheduler. Borrowed and modified from RxJS's Default Scheduler.
 //While it is probably more robust, this should fit the needs for
 //this project.
 
-class TaskQueue {
+class Scheduler {
   constructor(throttle = 0){
     this.nextTaskId = 1;
     this.tasks = {}
     this.isRunning = false;
     this.invokeLater = function (callback) { setTimeout(callback, throttle); }
   }
 
-  removeFromTaskQueue(taskId){
+  removeFromScheduler(taskId){
     delete this.tasks[taskId];
   }
 
@@ -23,7 +23,7 @@ class TaskQueue {
 
     for(let taskId of Object.keys(this.tasks)){
       if(this.tasks[taskId] && this.tasks[taskId][0] === pid){
-        this.removeFromTaskQueue(taskId);
+        this.removeFromScheduler(taskId);
       }
     }
 
@@ -50,7 +50,7 @@ class TaskQueue {
             result = e;
           }
 
-          this.removeFromTaskQueue(taskId);
+          this.removeFromScheduler(taskId);
           this.isRunning = false;
 
           if (result instanceof Error) {
@@ -62,7 +62,7 @@ class TaskQueue {
     }
   }
 
-  addToTaskQueue(pid, task, dueTime = 0) {
+  addToScheduler(pid, task, dueTime = 0) {
     let id = this.nextTaskId ++;
     this.tasks[id] = [ pid, task ];
 
@@ -75,13 +75,13 @@ class TaskQueue {
     return id;
   };
 
-  queue(pid, task){
-    this.addToTaskQueue(pid, () => { task(); });
+  schedule(pid, task){
+    this.addToScheduler(pid, () => { task(); });
   }
 
-  queueFuture(pid, dueTime, task){
-    this.addToTaskQueue(pid, () => { task(); }, dueTime);
+  scheduleFuture(pid, dueTime, task){
+    this.addToScheduler(pid, () => { task(); }, dueTime);
   }
 }
 
-export default TaskQueue;
+export default Scheduler;