c8a0366e929578b4d87024dc7f57b30dd873a87d,QUANTAXIS/QATask/QA_Queue_standard.py,QA_Queue,run,#QA_Queue#,79

Before Change

                        threading.current_thread()) + "Engine will waiting for new task ...")

            except:
                QA_util_log_info("From Engine %s" % str(
                    threading.current_thread()) + "Task has been finished!")
                //self.thread_stop = True
                break
            self.queue.task_done()  // 完成一个任务

After Change

                    else:
                        QA_util_log_info("From Engine %s" % str(threading.current_thread()) 
                         + "Engine will waiting for new task ...")
                        time.sleep(1)
                except:
                    time.sleep(1)
                    self.run()
                res = self.__QA_queue_status()  // 判断消息队列大小

Instances