git://git.onelab.eu
/
sfa.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
fix urn in GetVersion()
[sfa.git]
/
sfa
/
util
/
threadmanager.py
diff --git
a/sfa/util/threadmanager.py
b/sfa/util/threadmanager.py
old mode 100755
(executable)
new mode 100644
(file)
index
4ce578f
..
b47b818
--- a/
sfa/util/threadmanager.py
+++ b/
sfa/util/threadmanager.py
@@
-2,7
+2,7
@@
import threading
import traceback
import time
from Queue import Queue
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):
"""
def ThreadedMethod(callable, results, errors):
"""
@@
-31,9
+31,11
@@
class ThreadManager:
ThreadManager executes a callable in a thread and stores the result
in a thread safe queue.
"""
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):
"""
def run (self, method, *args, **kwds):
"""