LonamiWebs/Telethon
1
1
Fork 0
mirror of https://github.com/LonamiWebs/Telethon.git synced 2024-11-23 01:46:35 +03:00
Code Issues Packages Projects Releases Wiki Activity

Avoid receive busy wait when two threads receive items

Browse Source
This commit is contained in:
Lonami Exo 2018-05-10 09:44:25 +02:00
parent ef509d13c7
commit dd954b8fbd
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
telethon/network/mtproto_sender.py
View File

@ -152,7 +152,12 @@ class MtProtoSender:
Update and Updates objects. Update and Updates objects.
""" """
if self._recv_lock.locked(): if self._recv_lock.locked():
return with self._recv_lock:
# Don't busy wait, acquire it but return because there's
# already a receive running and we don't want another one.
# It would lock until Telegram sent another update even if
# the current receive already received the expected response.
return
try: try:
with self._recv_lock: with self._recv_lock: