went from Threads to Processes

Author: lp1tek

config.py

@@ -1,3 +1,4 @@
 run={
-    "hello_world":{"directory":"hello_world", "restart":False, "main_method":"main"}
+    "hello_world":{"directory":"hello_world", "restart":False, "main_method":"main"},
+    "tester":{"directory":"proxy_tester", "restart":False, "main_method":"main"}
 }

modules/commands.py

@@ -1,4 +1,4 @@
-commands = ["quit", "list", "start"]
+commands = ["quit", "list", "start", "kill"]
 
 def quit(worker, args=None):
     return 0
@@ -21,4 +21,5 @@ def start(worker, args=None):
             log.warning("Service %i is already running" %id)
 
 def kill(worker, args=None):
-    worker.kill(int(args[1]))
+    if len(args) > 1:
+        worker.kill(int(args[1]))

modules/service.py

@@ -1,5 +1,5 @@
 from importlib import import_module
-from threading import Thread
+from multiprocessing import Process
 import run
 
 class Service():
@@ -8,7 +8,7 @@ def __init__(self, service_name, service_conf):
         self.directory = service_conf['directory']
         self.keepAlive = service_conf['restart']
         self.main_method = service_conf['main_method']
-        self.thread = Thread(target=self.run, args=[])
+        self.process = Process(target=self.run, args=[])
 
     def setId(self, id):
         self.id = id
@@ -23,14 +23,14 @@ def run(self):
             eval(command)()
 
     def start(self):
-        self.thread.start()
+        self.process.start()
 
-    def restart(self, thread=None):
-        if thread is not None:
-            self.thread = thread
+    def restart(self, process=None):
+        if process is not None:
+            self.process = process
         else:
-            self.thread = Thread(target=self.run, args=[])
-        self.thread.start()
+            self.process = Process(target=self.run, args=[])
+        self.process.start()
 
     def isAlive(self):
-        return self.thread.isAlive()
+        return self.process.is_alive()

modules/worker.py

@@ -24,8 +24,8 @@ def add(self, service):
         self.services.append(service)
 
     def kill(self, id):
-        service = self.get_service(id)
+        service = self.getService(id)
         if service is None:
             log.warning("There is no service with id %i" %id)
             return
-        service.kill()
+        service.process.terminate()