update files

bin/emulator.js

@@ -4,8 +4,6 @@
 
 'use strict';
 
-var ipc = require('ipc-main');
-
 var spawn = require('child_process').spawn;
 
 /**
@@ -71,64 +69,5 @@ function normalizeExecArgs(command, options){
   };
 }
 
-var emulators = {};
+module.exports = Emulator;
 
-module.exports = {
-  Emulator: Emulator,
-  start: function (){
-    ipc.on('emulator', function (event, project, action){
-      var key = project.name + '-' + project.command.name;
-      var emulator = emulators[key];
-
-      switch (action) {
-        case 'start':
-          if (!emulator) {
-            var stream;
-            var env = {};
-
-            Object.keys(process.env).forEach(function (key){
-              env[key] = process.env[key];
-            });
-
-            project.env.forEach(function (item){
-              env[item.name] = item.value;
-            });
-
-            emulator = new Emulator({
-              env: env,
-              cwd: project.path,
-              command: project.command.value
-            });
-
-            stream = emulator.start();
-
-            stream.stdout.on('data', function (data){
-              event.sender.send('emulator', 'data', project, data);
-            });
-
-            stream.stderr.on('error', function (error){
-              event.sender.send('emulator', 'error', project, error);
-
-              emulator.stop();
-
-              delete emulators[key];
-            });
-
-            stream.on('close', function (signal){
-              event.sender.send('emulator', 'close', project, signal);
-
-              delete emulators[key];
-            });
-
-            emulators[key] = emulator;
-          }
-          break;
-        case 'stop':
-          if (emulator) {
-            emulator.stop();
-          }
-          break;
-      }
-    });
-  }
-};

bin/thread.js

@@ -0,0 +1,70 @@
+/**
+ * Created by nuintun on 2015/12/3.
+ */
+
+'use strict';
+
+var cluster = require('cluster');
+
+var ipc = require('ipc-main');
+
+// cache
+var workers = {};
+
+/**
+ * killWorker
+ * @param name
+ */
+function killWorker(name){
+  var worker = workers[name];
+
+  if (worker && !worker.isDead()) {
+    worker.kill('SIGTERM');
+
+    delete workers[name];
+  }
+}
+
+module.exports = {
+  start: function (){
+    ipc.on('emulator', function (event, project, action){
+      var key = project.name + '-' + project.command.name;
+      var worker = workers[key];
+
+      switch (action) {
+        case 'start':
+          if (!worker) {
+            var env = {};
+
+            Object.keys(process.env).forEach(function (key){
+              env[key] = process.env[key];
+            });
+
+            project.env.forEach(function (item){
+              env[item.name] = item.value;
+            });
+
+            worker = cluster.fork(env);
+
+            worker.on('message', function (message){
+              event.sender.send('emulator', message.event, message.project, message.data);
+            });
+
+            worker.on('error', function (){
+              killWorker(project.name);
+            });
+
+            delete project.env;
+
+            worker.send(project);
+
+            workers[project.name] = worker;
+          }
+          break;
+        case 'stop':
+          killWorker(project.name);
+          break;
+      }
+    });
+  }
+};