Revision 46d0a3d0 lib/workerpool.py

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