LonamiWebs/Telethon
1
1
Fork 0
mirror of https://github.com/LonamiWebs/Telethon.git synced 2024-11-25 10:53:44 +03:00
Code Issues Packages Projects Releases Wiki Activity

Make the UpdatesThread a daemon (closes #60)

Browse Source
This commit is contained in:
Lonami Exo 2017-04-29 10:41:56 +02:00
parent 89326c998a
commit a7595347f3
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
telethon/network/mtproto_sender.py
View File

@ -46,7 +46,8 @@ class MtProtoSender:
self.updates_thread_sleep = None self.updates_thread_sleep = None
self.updates_thread = Thread( self.updates_thread = Thread(
target=self.updates_thread_method, name='UpdatesThread') name='UpdatesThread', daemon=True,
target=self.updates_thread_method)
# The "updates" thread must also be running to make periodic ping requests. # The "updates" thread must also be running to make periodic ping requests.
self.set_updates_thread(running=True) self.set_updates_thread(running=True)
@ -399,13 +400,12 @@ class MtProtoSender:
# Always sleep a bit before each iteration to relax the CPU, # Always sleep a bit before each iteration to relax the CPU,
# since it's possible to early 'continue' the loop to reach # since it's possible to early 'continue' the loop to reach
# the next iteration, but we still should to sleep. # the next iteration, but we still should to sleep.
if self.updates_thread_running: if self.updates_thread_sleep:
if self.updates_thread_sleep: sleep(self.updates_thread_sleep)
sleep(self.updates_thread_sleep) self.updates_thread_sleep = None
self.updates_thread_sleep = None else:
else: # Longer sleep if we're not expecting updates (only pings)
# Longer sleep if we're not expecting updates (only pings) sleep(0.1 if self.on_update_handlers else 1)
sleep(0.1 if self.on_update_handlers else 1)
# Only try to receive updates if we're not waiting to receive a request # Only try to receive updates if we're not waiting to receive a request
if not self.waiting_receive: if not self.waiting_receive: