'Start the worker threads.'

def start(self):

    with self._state_change:
        if self._running:
            return
        for queue in (self.completion_queue, self.callback_queue):
            w = self._create_thread_worker(queue)
            self._workers.append(w)
        self._running = True
        atexit.register(self.stop)
