Skip to content

Commit

Permalink
refactor: use more simple wait function
Browse files Browse the repository at this point in the history
  • Loading branch information
shidenggui committed Sep 22, 2016
1 parent 7d58eb1 commit 253fdb1
Showing 1 changed file with 3 additions and 10 deletions.
13 changes: 3 additions & 10 deletions easyquant/push_engine/base_engine.py
Original file line number Diff line number Diff line change
Expand Up @@ -44,13 +44,6 @@ def init(self):
pass

def wait(self):
interval = self.PushInterval
if interval < 1:
time.sleep(interval)
return
else:
time.sleep(self.PushInterval - int(interval))
interval = int(interval)
while interval > 0 and self.is_active:
time.sleep(1)
interval -= 1
# for receive quit signal
for _ in range(int(self.PushInterval) + 1):
time.sleep(1)

0 comments on commit 253fdb1

Please sign in to comment.