[Add] OesGateway: TD API: Reconnect: Reduce CPU usage.

This commit is contained in:
nanoric 2019-03-15 00:01:00 -04:00
parent 459fc4770f
commit 9410775fb3

View File

@ -1,3 +1,4 @@
import time
from dataclasses import dataclass from dataclasses import dataclass
from datetime import datetime, timedelta, timezone from datetime import datetime, timedelta, timezone
from gettext import gettext as _ from gettext import gettext as _
@ -423,12 +424,10 @@ class OesTdApi:
def _reconnect_ord_channel(self): def _reconnect_ord_channel(self):
with self._reconnect_lock: # prevent spawning multiple reconnect thread with self._reconnect_lock: # prevent spawning multiple reconnect thread
if OesApi_IsValidOrdChannel(self._env.ordChannel):
return
self.gateway.write_log(_("正在重新连接到交易下单通道")) self.gateway.write_log(_("正在重新连接到交易下单通道"))
while not OesApi_IsValidOrdChannel(self._env.ordChannel): while not self._connect_ord_channel():
self._connect_ord_channel() time.sleep(1)
self.gateway.write_log(_("成功重新连接到交易下单通道")) self.gateway.write_log(_("成功重新连接到交易下单通道"))
def _schedule_reconnect_ord_channel(self): def _schedule_reconnect_ord_channel(self):