10919a8125c64db1fecee47d4480ae6c5c9f7224,QUANTAXIS/QAFetch/QATdx_adv.py,QA_Tdx_Executor,api_worker,#QA_Tdx_Executor#,147

Before Change

    def api_worker(self):
        // 将IP列表随机排序，避免只使用列表前面的IP地址
        ip_list = stock_ip_list
        random.shuffle(ip_list)
        for item in ip_list:
            if self._queue.full():
                return
            _sec = self._test_speed(ip=item["ip"], port=item["port"])
            if _sec < self.timeout*3:
                try:
                    self._queue.put(TdxHq_API(heartbeat=False).connect(
                        ip=item["ip"], port=item["port"], time_out=self.timeout*2))
                except:
                    pass

        Timer(300, self.api_worker).start()

    def _singal_job(self, context, id_, time_out=0.7):
        try:

After Change

    def api_worker(self):
        data = []
        if self._queue.qsize() < 80:
            for item in stock_ip_list:
                if self._queue.full():
                    break

Instances