The @synchronized and @synchronized_priority decorators now correctly…

… handle exceptions to avoid dead locks.

Version updated to 1.1.0

parallel_utils/process/decorators.py

@@ -20,9 +20,15 @@ def synchronized(max_threads: int = 1):
     def locked(func):
         @wraps(func)
         def locked_func(*args, **kw_args):
+            exceptions = []
             s.acquire()
-            res = func(*args, **kw_args)
+            try:
+                res = func(*args, **kw_args)
+            except Exception as e:
+                exceptions.append(e)
             s.release()
+            if len(exceptions):
+                raise exceptions[0]
             return res
 
         return locked_func
@@ -45,9 +51,15 @@ def synchronized_priority(uid: Union[str, int], order: int = 1, total: int = Non
         def locked(func):
             @wraps(func)
             def locked_func(*args, **kw_args):
+                exceptions = []
                 m.lock_priority_code(uid=uid, order=order, total=total)
-                res = func(*args, **kw_args)
+                try:
+                    res = func(*args, **kw_args)
+                except Exception as e:
+                    exceptions.append(e)
                 m.unlock_code(uid=uid)
+                if len(exceptions):
+                    raise exceptions[0]
                 return res
 
             return locked_func

parallel_utils/thread/decorators.py

@@ -10,19 +10,25 @@
 
 
 def synchronized(max_threads: int = 1):
-    '''
+    """
     This decorator will allow only up to max_threads threads to run this function simultaneously.
     :param max_threads: Maximum number of threads.
-    '''
+    """
 
     s = Semaphore(max_threads)
 
     def locked(func):
         @wraps(func)
         def locked_func(*args, **kw_args):
+            exceptions = []
             s.acquire()
-            res = func(*args, **kw_args)
+            try:
+                res = func(*args, **kw_args)
+            except Exception as e:
+                exceptions.append(e)
             s.release()
+            if len(exceptions):
+                raise exceptions[0]
             return res
 
         return locked_func
@@ -34,20 +40,26 @@ def synchronized_priority(*args, **kwargs):
     m = Monitor()
 
     def synchronized_priority(uid: Union[str, int], order: int = 1, total: int = None):
-        '''
+        """
         This decorator will synchronize different threads to execute some functions
         in a specific order to avoid race conditions.
         :param uid: Unique identifier for the set of code snippets.
         :param order: The priority of the function protected with this function's uid.
         :param total: The total number of functions to synchronize using this function's uid.
-        '''
+        """
 
         def locked(func):
             @wraps(func)
             def locked_func(*args, **kw_args):
+                exceptions = []
                 m.lock_priority_code(uid=uid, order=order, total=total)
-                res = func(*args, **kw_args)
+                try:
+                    res = func(*args, **kw_args)
+                except Exception as e:
+                    exceptions.append(e)
                 m.unlock_code(uid=uid)
+                if len(exceptions):
+                    raise exceptions[0]
                 return res
 
             return locked_func

setup.py

@@ -7,7 +7,7 @@
 name = 'parallel-utils'
 
 # https://www.python.org/dev/peps/pep-0440/#version-scheme
-version = '1.0.0'
+version = '1.1.0'
 
 description = 'This library implements a class Monitor, as defined by Per Brinch Hansen and C.A.R. Hoare, ' \
               'for synchronization and concurrent management of threads and processes in Python. It also provides other ' \