word2vec.py termination condition

word2vec.py

        while not self.jobs_finished or self.jobs_left > 0:
            try:
                report = progress_queue.get(timeout=2)  # blocks if workers too slow
            except Empty:
                logger.info("Jobs left: %d" % self.jobs_left)
                logger.info("Job queue size: %i" % utils.qsize(job_queue))
                if self.jobs_finished:
                    import time
                    logger.info("Sleeping 10 secs.")
                    time.sleep(10)
                    logger.info("Jobs left: %d" % self.jobs_left)
                    logger.info("Job queue size: %i" % utils.qsize(job_queue))
                    break
                continue
            if report is None:
                continue
            examples, trained_words, raw_words = report