Add PID class

Author: bryanjos

src/processes/pid.js

@@ -0,0 +1,18 @@
+"use strict";
+/* @flow */
+
+let process_counter = -1;
+
+class PID {
+  constructor(){
+    process_counter = process_counter + 1;
+    this.id = process_counter;
+  }
+
+  toString(){
+    return "PID#<0." + id + ".0>";
+  }
+}
+
+
+export default PID;

src/processes/process_system.js

@@ -5,11 +5,11 @@ import Mailbox from "./mailbox";
 import Process from "./process";
 import States from "./states";
 import Scheduler from "./scheduler";
+import PID from "./pid";
 
 class ProcessSystem {
 
   constructor(){
-    this.process_counter = -1;
     this.pids = new Map();
     this.mailboxes = new Map();
     this.names = new Map();
@@ -83,8 +83,7 @@ class ProcessSystem {
   }
 
   add_proc(fun, args, linked){
-    this.process_counter = this.process_counter + 1;
-    let newpid = this.process_counter;
+    let newpid = new PID();
     let mailbox = new Mailbox();
     let newproc = new Process(newpid, fun, args, mailbox, this);
 
@@ -141,7 +140,7 @@ class ProcessSystem {
   }
 
   pidof(id){
-    if (typeof(id) === "number") {
+    if (id instanceof PID) {
        return this.pids.has(id) ? id : null;
     } else if (id instanceof Process) {
        return id.pid;

src/processes/scheduler.js

@@ -1,5 +1,6 @@
 "use strict";
 
+// A reduction is equal to a function call
 const MAX_REDUCTIONS_PER_PROCESS = 8;
 
 class ProcessQueue {
@@ -25,22 +26,22 @@ class Scheduler {
   constructor(throttle = 0){
     this.isRunning = false;
     this.invokeLater = function (callback) { setTimeout(callback, throttle); }
-    this.queues = {};
+    this.queues = new Map();
     this.run();
   }
 
   addToQueue(pid, task){
-    if(!this.queues[pid]){
-      this.queues[pid] = new ProcessQueue(pid);
+    if(!this.queues.has(pid)){
+      this.queues.set(pid, new ProcessQueue(pid));
     }
 
-    this.queues[pid].add(task);
+    this.queues.get(pid).add(task);
   }
 
   removePid(pid){
     this.isRunning = true;
 
-    delete this.queues[pid];
+    this.queues.delete(pid);
 
     this.isRunning = false;
   }
@@ -49,10 +50,10 @@ class Scheduler {
     if (this.isRunning) {
       this.invokeLater(() => { this.run(); });
     } else {
-      for(let pid of Object.keys(this.queues)){
+      for(let [pid, queue] of this.queues){
         let reductions = 0;
-        while(this.queues[pid] && !this.queues[pid].empty() && reductions < MAX_REDUCTIONS_PER_PROCESS){
-          let task = this.queues[pid].next();
+        while(queue && !queue.empty() && reductions < MAX_REDUCTIONS_PER_PROCESS){
+          let task = queue.next();
           this.isRunning = true;
 
           let result;