import traceback
import time
from Queue import Queue
-from sfa.util.sfa.logging import logger
+from sfa.util.sfalogging import logger
def ThreadedMethod(callable, results, errors):
"""
ThreadManager executes a callable in a thread and stores the result
in a thread safe queue.
"""
- results = Queue()
- errors = Queue()
- threads = []
+
+ def __init__(self):
+ self.results = Queue()
+ self.errors = Queue()
+ self.threads = []
def run (self, method, *args, **kwds):
"""