(self)
return self.pool_res.ready() and self.mp_queue.qsize() == 0
Whether all data have been consumed.
Whether all data have been consumed.
Whether all data have been consumed .
def done(self):
    ''' Whether all data have been consumed. '''
    return self.pool_res.ready() and self.mp_queue.qsize() == 0
def done ( self ) : return self . pool_res . ready ( ) and self . mp_queue . qsize ( ) == 0