tobias/docker-offlineimap
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

threading: get rid of the syncaccount function

Browse Source 
Signed-off-by: Nicolas Sebrecht <nicolas.s-dev@laposte.net>
This commit is contained in:
Nicolas Sebrecht 2016-05-17 02:38:35 +02:00
parent 7ab18276f9
commit c843f34876
1 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
offlineimap/init.py
View File

@ -36,24 +36,22 @@ import traceback
import collections import collections
def syncaccount(config, accountname): def syncitall(list_accounts, config):
"""Return a new running thread for this account."""
account = accounts.SyncableAccount(config, accountname)
thread = threadutil.InstanceLimitedThread(instancename = 'ACCOUNTLIMIT',
target = account.syncrunner,
name = "Account sync %s" % accountname)
thread.setDaemon(True)
thread.start()
return thread
def syncitall(accounts, config):
"""The target when in multithreading mode for running accounts threads.""" """The target when in multithreading mode for running accounts threads."""
threads = threadutil.accountThreads() # The collection of accounts threads. threads = threadutil.accountThreads() # The collection of accounts threads.
for accountname in accounts: for accountname in list_accounts:
# Start a new thread per account and store it in the collection. # Start a new thread per account and store it in the collection.
threads.add(syncaccount(config, accountname)) account = accounts.SyncableAccount(config, accountname)
thread = threadutil.InstanceLimitedThread(
instancename = 'ACCOUNTLIMIT',
target = account.syncrunner,
name = "Account sync %s"% accountname
)
thread.setDaemon(True)
# The add() method expects a started thread.
thread.start()
threads.add(thread)
# Wait for the threads to finish. # Wait for the threads to finish.
threads.wait() # Blocks until all accounts are processed. threads.wait() # Blocks until all accounts are processed.
@ -410,9 +408,11 @@ class OfflineImap:
self.__sync_singlethreaded(syncaccounts) self.__sync_singlethreaded(syncaccounts)
else: else:
# multithreaded # multithreaded
t = threadutil.ExitNotifyThread(target=syncitall, t = threadutil.ExitNotifyThread(
target=syncitall,
name='Sync Runner', name='Sync Runner',
kwargs={'accounts': syncaccounts, 'config': self.config}) args=(syncaccounts, self.config,)
)
# Special exit message for the monitor to stop looping. # Special exit message for the monitor to stop looping.
t.exit_message = threadutil.STOP_MONITOR t.exit_message = threadutil.STOP_MONITOR
t.start() t.start()