'Process task by sending it to the pool of workers.'

def _process_task(self, req):

    try:
        req.execute_using_pool(self.pool)
    except TaskRevokedError:
        try:
            self._quick_release()
        except AttributeError:
            pass
