libasynctasks: better handling of exceptions for all threads...

src/_threading.pyx

@@ -0,0 +1,19 @@
+import time
+
+from cpython.exc cimport PyErr_CheckSignals
+
+
+def thread_wait():
+    """
+    Wait for a short amount of time before executing anymore
+    code on the thread, this reduces overall idle CPU usage...
+    """
+
+    # check for Python error signals so we can except
+    # errors like KeyboardInterrupt, SystemExit etc...
+    PyErr_CheckSignals()
+
+    # hault the current thread for a short amount of time,
+    # so that we use less CPU usage when idling to free up the
+    # CPU for other running processes...
+    time.sleep(0.0001)

src/libasynctasks.pyx

@@ -3,12 +3,12 @@ A framework built to make concurrency fast, simple and dynamic;
 using the Task concept (and soon to support coroutines async/await...).
 """
 
-from cpython.exc cimport PyErr_CheckSignals
-
 import threading
 import time
 import collections
 
+include "_threading.pyx"
+
 
 ctypedef enum TaskResult:
     TASK_DONE,
@@ -503,10 +503,6 @@ cdef class TaskManager(object):
             except (KeyboardInterrupt, SystemExit):
                 break
 
-            # check for Python error signals so we can except
-            # errors like KeyboardInterrupt, SystemExit etc...
-            PyErr_CheckSignals()
-
             thread_wait()
 
         self.destroy()
@@ -516,12 +512,3 @@ cdef class TaskManager(object):
         self._task_queue = None
 
         super().__del__()
-
-
-cdef void thread_wait():
-    """
-    Wait for a short amount of time before executing anymore
-    code on the thread, this reduces overall idle CPU usage...
-    """
-
-    time.sleep(0.0001)