'Start the processing worker threads.'

def start(self, session, coordinator, num_concurrent=4):

    session.run(self.enqueue_paths_op)
    session.run(self.close_path_queue_op)
    return self.queue_runner.create_threads(session, coord=coordinator, start=True)
