daemon option for supervisor

alttch · Aug 20, 2019 · fd3e23f · fd3e23f
1 parent 2e4c3b2
commit fd3e23f
Show file tree

Hide file tree

Showing 10 changed files with 13 additions and 11 deletions.
diff --git a/atasker/__init__.py b/atasker/__init__.py
@@ -1,7 +1,7 @@
 __author__ = "Altertech Group, https://www.altertech.com/"
 __copyright__ = "Copyright (C) 2018-2019 Altertech Group"
 __license__ = "Apache License 2.0"
-__version__ = "0.2.15"
+__version__ = "0.2.16"
 
 from atasker.supervisor import TaskSupervisor
 from atasker.supervisor import TASK_LOW

diff --git a/atasker/co.py b/atasker/co.py
@@ -1,7 +1,7 @@
 __author__ = "Altertech Group, https://www.altertech.com/"
 __copyright__ = "Copyright (C) 2018-2019 Altertech Group"
 __license__ = "Apache License 2.0"
-__version__ = "0.2.15"
+__version__ = "0.2.16"
 
 from atasker import task_supervisor
 

diff --git a/atasker/f.py b/atasker/f.py
@@ -1,7 +1,7 @@
 __author__ = "Altertech Group, https://www.altertech.com/"
 __copyright__ = "Copyright (C) 2018-2019 Altertech Group"
 __license__ = "Apache License 2.0"
-__version__ = "0.2.15"
+__version__ = "0.2.16"
 
 import traceback
 import threading

diff --git a/atasker/supervisor.py b/atasker/supervisor.py
@@ -1,7 +1,7 @@
 __author__ = "Altertech Group, https://www.altertech.com/"
 __copyright__ = "Copyright (C) 2018-2019 Altertech Group"
 __license__ = "Apache License 2.0"
-__version__ = "0.2.15"
+__version__ = "0.2.16"
 
 import threading
 import multiprocessing
@@ -66,6 +66,7 @@ def __init__(self):
         self._task_info = {}
         self.default_async_executor_loop = None
         self.mp_pool = None
+        self.daemon = False
 
         self.set_thread_pool(pool_size=thread_pool_default_size,
                              reserve_normal=default_reserve_normal,
@@ -289,7 +290,8 @@ def start(self):
         self._active = True
         self._main_loop_active = True
         t = threading.Thread(name='supervisor_event_loop',
-                             target=self._start_event_loop)
+                             target=self._start_event_loop,
+                             daemon=self.daemon)
         t.start()
         self._started.wait()
 

diff --git a/atasker/threads.py b/atasker/threads.py
@@ -1,7 +1,7 @@
 __author__ = "Altertech Group, https://www.altertech.com/"
 __copyright__ = "Copyright (C) 2018-2019 Altertech Group"
 __license__ = "Apache License 2.0"
-__version__ = "0.2.15"
+__version__ = "0.2.16"
 
 import threading
 import time

diff --git a/atasker/workers.py b/atasker/workers.py
@@ -1,7 +1,7 @@
 __author__ = "Altertech Group, https://www.altertech.com/"
 __copyright__ = "Copyright (C) 2018-2019 Altertech Group"
 __license__ = "Apache License 2.0"
-__version__ = "0.2.15"
+__version__ = "0.2.16"
 
 import threading
 import logging

diff --git a/setup.py b/setup.py
@@ -1,4 +1,4 @@
-__version__ = "0.2.15"
+__version__ = "0.2.16"
 
 import setuptools
 

diff --git a/tests/mp.py b/tests/mp.py
@@ -1,7 +1,7 @@
 __author__ = "Altertech Group, https://www.altertech.com/"
 __copyright__ = "Copyright (C) 2018-2019 Altertech Group"
 __license__ = "Apache License 2.0"
-__version__ = "0.2.15"
+__version__ = "0.2.16"
 
 def test(*args, **kwargs):
     print('test mp method {} {}'.format(args, kwargs))

diff --git a/tests/mpworker.py b/tests/mpworker.py
@@ -1,7 +1,7 @@
 __author__ = "Altertech Group, https://www.altertech.com/"
 __copyright__ = "Copyright (C) 2018-2019 Altertech Group"
 __license__ = "Apache License 2.0"
-__version__ = "0.2.15"
+__version__ = "0.2.16"
 
 from atasker import BackgroundIntervalWorker
 

diff --git a/tests/test.py b/tests/test.py
@@ -3,7 +3,7 @@
 __author__ = "Altertech Group, https://www.altertech.com/"
 __copyright__ = "Copyright (C) 2018-2019 Altertech Group"
 __license__ = "Apache License 2.0"
-__version__ = "0.2.15"
+__version__ = "0.2.16"
 
 from pathlib import Path