implemented main loop

kernel.js

@@ -35,35 +35,35 @@ module.exports = class Kernel {
    */
   queue (portName, message) {
     this.ports.queue(portName, message)
-    if (this.containerState !== 'running') {
-      this.containerState = 'running'
-      return this._runNextMessage()
-    }
+    return this._startMessageLoop()
   }
 
-  initialize (message) {
-    this.containerState = 'running'
-    return this.run(message, 'initialize')
+  async initialize (message) {
+    await this.run(message, 'initialize')
+    return this._startMessageLoop()
   }
 
   // waits for the next message
-  async _runNextMessage () {
-    // check if the ports are saturated, if so we don't have to wait on the
-    // scheduler
-    const message = await this.ports.getNextMessage()
-
-    if (message) {
-      message.fromPort.messages.shift()
-      // if the message we recived had more ticks then we currently have the
-      // update it
-      if (message._fromTicks > this.ticks) {
-        this.ticks = message._fromTicks
-        this.hypervisor.scheduler.update(this)
+  async _startMessageLoop () {
+    // this ensure we only every have one loop running at a time
+    if (this.containerState !== 'running') {
+      this.containerState = 'running'
+
+      while (1) {
+        let message = await this.ports.getNextMessage()
+        if (!message) break
+
+        message.fromPort.messages.shift()
+          // if the message we recived had more ticks then we currently have the
+          // update it
+        if (message._fromTicks > this.ticks) {
+          this.ticks = message._fromTicks
+          this.hypervisor.scheduler.update(this)
+        }
+        // run the next message
+        await this.run(message)
       }
-      // run the next message
-      return this.run(message)
-    } else {
-      // if no more messages then shut down
+      // no more messages; shut down
       this.hypervisor.scheduler.done(this.id)
     }
   }
@@ -100,11 +100,9 @@ module.exports = class Kernel {
       this.send(responsePort, new Message({
         data: result
       }))
-      this.ports._unboundPorts.add(responsePort)
     }
 
     this.ports.clearUnboundedPorts()
-    return this._runNextMessage()
   }
 
   getResponsePort (message) {