mirror/pyTelegramBotAPI
1
0
Fork 0
mirror of https://github.com/eternnoir/pyTelegramBotAPI.git synced 2023-08-10 21:12:57 +03:00
Code Releases Activity

Create ThreadPool when creat_thread flag is True.

Browse Source
This commit is contained in:
eternnoir 2015-07-04 19:51:06 +08:00
parent b316e699e1
commit da176b770c
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
telebot/__init__.py
View File

@ -87,10 +87,11 @@ class TeleBot:
self.__stop_polling = False self.__stop_polling = False
self.last_update_id = 0 self.last_update_id = 0
self.num_threads = num_threads self.num_threads = num_threads
self.create_threads = create_threads self.__create_threads = create_threads
self.message_handlers = [] self.message_handlers = []
self.worker_pool = ThreadPool(num_threads) if self.__create_threads:
self.worker_pool = ThreadPool(num_threads)
def get_update(self): def get_update(self):
""" """
@ -112,7 +113,7 @@ class TeleBot:
def __notify_update(self, new_messages): def __notify_update(self, new_messages):
for listener in self.update_listener: for listener in self.update_listener:
if self.create_threads: if self.__create_threads:
self.worker_pool.put(listener, new_messages) self.worker_pool.put(listener, new_messages)
else: else:
listener(new_messages) listener(new_messages)
@ -366,7 +367,7 @@ class TeleBot:
for message in new_messages: for message in new_messages:
for message_handler in self.message_handlers: for message_handler in self.message_handlers:
if self._test_message_handler(message_handler, message): if self._test_message_handler(message_handler, message):
if self.create_threads: if self.__create_threads:
self.worker_pool.put(message_handler['function'], message) self.worker_pool.put(message_handler['function'], message)
# t = threading.Thread(target=message_handler['function'], args=(message,)) # t = threading.Thread(target=message_handler['function'], args=(message,))
# t.start() # t.start()