Revision 46d0a3d0

b/lib/workerpool.py
78 78 
    """
79 79 
    pool = self.pool
80 80 

  		





  81
  
  
    
    assert self._current_task is None


  		





  82
  
  
    

  		





  83
  81
  
    
    while True:


  		





  
  82
  
    
      assert self._current_task is None


  		





  84
  83
  
    
      try:


  		





  85
  84
  
    
        # Wait on lock to be told either to terminate or to do a task


  		





  86
  85
  
    
        pool._lock.acquire()


  		





  ......




  97
  96
  
    

  		





  98
  97
  
    
          self._current_task = task


  		





  99
  98
  
    

  		





  
  99
  
    
          # No longer needed, dispose of reference


  		





  
  100
  
    
          del task


  		





  
  101
  
    

  		





  100
  102
  
    
          assert self._HasRunningTaskUnlocked()


  		





  
  103
  
    

  		





  101
  104
  
    
        finally:


  		





  102
  105
  
    
          pool._lock.release()


  		





  103
  106
  
    

  		












Also available in:
  Unified diff