'Release the current thread and run \'stop_thread\' listeners.'

def release_thread(self):

    thread_ident = get_thread_ident()
    i = self.threads.pop(thread_ident, None)
    if (i is not None):
        self.bus.publish('stop_thread', i)
