public/wallabicher
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Migrate to concurrent futures

Browse Source
This commit is contained in:
danielhuici
2024-10-29 20:31:42 +01:00
parent b3e5a1b0a1
commit ab8b506ea2
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
main.py
View File

@@ -1,9 +1,11 @@
import json import json
import threading
import logging import logging
from logging.handlers import RotatingFileHandler from logging.handlers import RotatingFileHandler
from concurrent.futures import ThreadPoolExecutor
from datalayer.item_monitor import ItemMonitor from datalayer.item_monitor import ItemMonitor
from worker import Worker from worker import Worker
from managers.telegram_manager import TelegramManager
def configure_logger(): def configure_logger():
console_handler = logging.StreamHandler() console_handler = logging.StreamHandler()
@@ -28,7 +30,8 @@ if __name__ == "__main__":
configure_logger() configure_logger()
items = parse_items_to_monitor() items = parse_items_to_monitor()
for item in items: with ThreadPoolExecutor(max_workers=10) as executor:
worker = Worker(item) for item in items:
thread = threading.Thread(target=worker.run) worker = Worker(item)
thread.start() executor.submit(worker.run)