synchronize thread start/stop methods

MailHost.py

@@ -20,6 +20,7 @@
 import time
 import logging
 from cStringIO import StringIO
+from threading import Lock
 
 import Acquisition
 import OFS.SimpleItem
@@ -38,6 +39,7 @@
                             QueueProcessorThread
 
 from interfaces import IMailHost
+from decorator import synchronized
 
 queue_threads = {}  # maps MailHost path -> queue processor threada
 
@@ -74,8 +76,10 @@ class MailBase(Acquisition.Implicit, OFS.SimpleItem.Item, RoleManager):
     smtp_pwd=''
     smtp_queue = False
     smtp_queue_directory = '/tmp'
+    lock = Lock()
 
-    timeout=1.0
+    # timeout=1.0 # unused?
+
 
     manage_options=(
         (
@@ -187,6 +191,7 @@ def _makeMailer(self):
                           self.smtp_pwd or None
                           )
 
+    @synchronized(lock)
     def _stopQueueProcessorThread(self):
         """ Stop thread for processing the mail queue """
 
@@ -200,6 +205,7 @@ def _stopQueueProcessorThread(self):
             del queue_threads[path]
             LOG.info('Thread for %s stopped' % path)
 
+    @synchronized(lock)
     def _startQueueProcessorThread(self):
         """ Start thread for processing the mail queue """
 

decorator.py

@@ -0,0 +1,30 @@
+##############################################################################
+#
+# Copyright (c) 2002 Zope Corporation and Contributors. All Rights Reserved.
+#
+# This software is subject to the provisions of the Zope Public License,
+# Version 2.1 (ZPL).  A copy of the ZPL should accompany this distribution.
+# THIS SOFTWARE IS PROVIDED "AS IS" AND ANY AND ALL EXPRESS OR IMPLIED
+# WARRANTIES ARE DISCLAIMED, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+# WARRANTIES OF TITLE, MERCHANTABILITY, AGAINST INFRINGEMENT, AND FITNESS
+# FOR A PARTICULAR PURPOSE.
+#
+##############################################################################
+"""
+Decorator(s)
+
+$Id: MailHost.py 78992 2007-08-19 11:58:08Z andreasjung $
+"""
+
+def synchronized(lock):
+    """ Decorator for method synchronization. """
+
+    def wrapper(f):
+        def method(*args, **kw):
+            lock.acquire()
+            try:
+                return f(*args, **kw)
+            finally:
+                lock.release()
+        return method
+    return wrapper