4dfc719192396ee993e1eb23d3820fa420fb3bbc,QUANTAXIS/QATask/QA_Queue_standard.py,QA_Queue,run,#QA_Queue#,70

Before Change

                QA_util_log_info("From Engine==="+str(datetime.datetime.now()))

            except:
                QA_util_log_info("Task has been finished!")
                self.thread_stop = True
                break
            self.queue.task_done()  // 完成一个任务
            res = self.__QA_queue_status()  // 判断消息队列大小

After Change

            self.queue.task_done()  // 完成一个任务
            res = self.__QA_queue_status()  // 判断消息队列大小
            if res > 0:
                QA_util_log_info("From Engine %s: There are still %d tasks to do" % (str(threading.current_thread()),res))

    def stop(self):
        self.thread_stop = True

Instances