RTAkland/QWeatherReporter
Archived
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

feat: change multiprocessing to concurrent

Browse Source
This commit is contained in:
RTAkland
2021-12-18 21:40:48 +08:00
parent 59f6561159
commit ae2cfce166
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
core/qweather.py
View File

@@ -9,12 +9,13 @@
import sys import sys
import time import time
import argparse import argparse
from concurrent.futures import ProcessPoolExecutor
from core.logger import Logger from core.logger import Logger
from core.language import Language from core.language import Language
from core.settings import change_settings from core.settings import change_settings
from tests import webserver
from core import read_config from core import read_config
from core.sendmail import Mail from core.sendmail import Mail
from multiprocessing import Process
def check_time(): def check_time():
@@ -72,8 +73,9 @@ def main():
Logger.debug(f'{language["debug_done"]}') Logger.debug(f'{language["debug_done"]}')
case _: case _:
pass pass
processes.submit(check_time)
Process(target=check_time).run() if settings[2]['webserver']:
processes.submit(webserver.process_request())
time_count = 0 time_count = 0
while True: while True:
@@ -87,6 +89,7 @@ def main():
if __name__ != '__main__': if __name__ != '__main__':
language = Language() language = Language()
settings = read_config() settings = read_config()
processes = ProcessPoolExecutor(max_workers=3)
Logger.info(f'{language["statement_1"]}') Logger.info(f'{language["statement_1"]}')
Logger.info(f'{language["statement_2"]}') Logger.info(f'{language["statement_2"]}')