Changeset 236 for tbroadcast/v2/python

Timestamp:

Aug 26, 2006, 11:07:28 AM (18 years ago)

Author:

garonne

Message:

MàJ

Location:

tbroadcast/v2/python

Files:

• tbroadcast.py (modified) (1 diff)
• threadpool.py (modified) (1 diff)

tbroadcast/v2/python/tbroadcast.py

@@ -22 +22 @@
 class Scheduler:
 
-    def __init__(self, num_worker=20):
-        self.pool     = ThreadPool(num_worker)
+    def __init__(self, num_workers=20):
+        self.pool     = ThreadPool(num_workers=num_workers)
         self.packages = {}  
         self.instanciate_packages ()      

tbroadcast/v2/python/threadpool.py

@@ -194 +194 @@
 
         assert isinstance(request, WorkRequest)
-        self.requestsQueue.put(request, block, timeout)
+        self.requestsQueue.put(item=request, block=block)#,timeout=timeout)
         self.workRequests[request.requestID] = request