From 74ae944b06b3d2372e151868478ddb923d33a54c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Rodolfo=20Garc=C3=ADa=20Pe=C3=B1as=20=28kix=29?= Date: Sat, 29 Aug 2020 20:22:53 +0200 Subject: [PATCH] Reformat offlineimap/threadutil.py Add some spaces, remove lines,... now format is better (lintian). --- offlineimap/threadutil.py | 18 ++++++++++-------- 1 file changed, 10 insertions(+), 8 deletions(-) diff --git a/offlineimap/threadutil.py b/offlineimap/threadutil.py index fc0da61..61e3545 100644 --- a/offlineimap/threadutil.py +++ b/offlineimap/threadutil.py @@ -20,12 +20,11 @@ from queue import Queue, Empty import traceback from offlineimap.ui import getglobalui - STOP_MONITOR = 'STOP_MONITOR' -###################################################################### + # General utilities -###################################################################### + def semaphorereset(semaphore, originalstate): """Block until `semaphore` gets back to its original state, ie all acquired @@ -37,6 +36,7 @@ def semaphorereset(semaphore, originalstate): for i in range(originalstate): semaphore.release() + class accountThreads(object): """Store the list of all threads in the software so it can be used to find out what's running and what's not.""" @@ -73,6 +73,7 @@ class accountThreads(object): exitedThreads = Queue() + def monitor(): """An infinite "monitoring" loop watching for finished ExitNotifyThread's. @@ -111,16 +112,16 @@ def monitor(): # Do not send it back to UI layer right now. # Maybe later send it to ui.terminate? raise SystemExit - ui.threadException(thread) # Expected to terminate the program. + ui.threadException(thread) # Expected to terminate the program. # Should never hit this line. raise AssertionError("thread has 'exit_exception' set to" - " '%s' [%s] but this value is unexpected" - " and the ui did not stop the program."% - (repr(thread.exit_exception), type(thread.exit_exception))) + " '%s' [%s] but this value is unexpected" + " and the ui did not stop the program." % + (repr(thread.exit_exception), type(thread.exit_exception))) # Only the monitor thread has this exit message set. elif thread.exit_message == STOP_MONITOR: - break # Exit the loop here. + break # Exit the loop here. else: ui.threadExited(thread) except Empty: @@ -189,6 +190,7 @@ class ExitNotifyThread(Thread): limitedNamespaces = {} + def initInstanceLimit(limitNamespace, instancemax): """Initialize the instance-limited thread implementation.