yasirarism/pyrofork
1
0
Fork 0
mirror of https://github.com/Mayuri-Chan/pyrofork.git synced 2026-01-08 16:04:51 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Clear thread lists when stopping. Related to #62

Browse source
This commit is contained in:
Dan 2018-04-29 20:20:34 +02:00
parent 68cd19baa4
commit 33c417942c
2 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
pyrogram/client/client.py
View file

@ -385,12 +385,16 @@ class Client:
for i in self.updates_workers_list: for i in self.updates_workers_list:
i.join() i.join()
self.updates_workers_list.clear()
for _ in range(self.DOWNLOAD_WORKERS): for _ in range(self.DOWNLOAD_WORKERS):
self.download_queue.put(None) self.download_queue.put(None)
for i in self.download_workers_list: for i in self.download_workers_list:
i.join() i.join()
self.download_workers_list.clear()
self.dispatcher.stop() self.dispatcher.stop()
self.is_started = False self.is_started = False

2
pyrogram/client/dispatcher/dispatcher.py
View file

@ -68,6 +68,8 @@ class Dispatcher:
for i in self.workers_list: for i in self.workers_list:
i.join() i.join()
self.workers_list.clear()
def add_handler(self, handler, group: int): def add_handler(self, handler, group: int):
if group not in self.groups: if group not in self.groups:
self.groups[group] = [] self.groups[group] = []