'Process any new results in the queue.'

def poll(self, block=False):

    while True:
        if (not self.workRequests):
            raise NoResultsPending
        elif (block and (not self.workers)):
            raise NoWorkersAvailable
        try:
            (request, result) = self.resultsQueue.get(block=block)
            if (request.exception and request.exc_callback):
                request.exc_callback(request, result)
            if (request.callback and (not (request.exception and request.exc_callback))):
                request.callback(request, result)
            del self.workRequests[request.requestID]
        except Queue.Empty:
            break
