'Create a :class:`SequentialThreadingHandler` instance'

def __init__(self):

    self.callback_queue = self.queue_impl()
    self.completion_queue = self.queue_impl()
    self._running = False
    self._state_change = threading.Lock()
    self._workers = []
