Revision f94779f5

b/lib/workerpool.py
336 336 
      assert compat.all(isinstance(prio, (int, long)) for prio in priority)
337 337 
      assert len(tasks) == len(priority)
338 338 

  		





  339
  
  
    
      for args, priority in zip(tasks, priority):


  		





  340
  
  
    
        self._AddTaskUnlocked(args, priority)


  		





  
  339
  
    
      for args, prio in zip(tasks, priority):


  		





  
  340
  
    
        self._AddTaskUnlocked(args, prio)


  		





  341
  341
  
    
    finally:


  		





  342
  342
  
    
      self._lock.release()


  		





  343
  343
  
    

  		












Also available in:
  Unified diff