Changeset 236 for tbroadcast


Ignore:
Timestamp:
Aug 26, 2006, 11:07:28 AM (18 years ago)
Author:
garonne
Message:

MàJ

Location:
tbroadcast/v2
Files:
3 edited

Legend:

Unmodified
Added
Removed

  • tbroadcast/v2/python/tbroadcast.py

    r232 r236  
    2222class Scheduler:
    2323
    24     def __init__(self, num_worker=20):
    25         self.pool     = ThreadPool(num_worker)
     24    def __init__(self, num_workers=20):
     25        self.pool     = ThreadPool(num_workers=num_workers)
    2626        self.packages = {} 
    2727        self.instanciate_packages ()     

  • tbroadcast/v2/python/threadpool.py

    r232 r236  
    194194
    195195        assert isinstance(request, WorkRequest)
    196         self.requestsQueue.put(request, block, timeout)
     196        self.requestsQueue.put(item=request, block=block)#,timeout=timeout)
    197197        self.workRequests[request.requestID] = request
    198198

  • tbroadcast/v2/scripts/tbroadcast

    r235 r236  
    1 #!/usr/bin/env python
     1#!/usr/bin/env python2
    22#----------------------------------#
    33# -- Author: V.Garonne
    … …  
    1717    if len(sys.argv) ==1 :
    1818        print 'Usage : > tbroadcast [-nb=<num_worker>] <command>'
    19         sys.exit(-1)
    20    
     19        sys.exit(-1)   
    2120    num_worker = 20   
    2221    for arg in sys.argv:           
    … …  
    2928    # we create a pool of num_worker worker threads
    3029    print 'num_worker', num_worker , command
    31     master = Scheduler (num_worker=num_worker)       
     30    master = Scheduler (num_workers=num_worker)       
    3231    master.execute_all (command)
    3332
Note: See TracChangeset for help on using the changeset viewer.