This commit is contained in:
jxxghp
2025-06-14 08:23:48 +08:00
parent c32c37e66a
commit c86ed20c34

View File

@@ -18,6 +18,7 @@ from app.core.event import Event, eventmanager
from app.log import logger from app.log import logger
from app.schemas import ConfigChangeEventData from app.schemas import ConfigChangeEventData
from app.schemas.types import EventType from app.schemas.types import EventType
from app.utils.singleton import Singleton
# 定义一个全局线程池执行器 # 定义一个全局线程池执行器
_executor = concurrent.futures.ThreadPoolExecutor() _executor = concurrent.futures.ThreadPoolExecutor()
@@ -67,13 +68,12 @@ def enable_doh(enable: bool):
else: else:
socket.getaddrinfo = _orig_getaddrinfo socket.getaddrinfo = _orig_getaddrinfo
class DohHelper: class DohHelper(metaclass=Singleton):
def __init__(self): def __init__(self):
enable_doh(settings.DOH_ENABLE) enable_doh(settings.DOH_ENABLE)
@eventmanager.register(EventType.ConfigChanged) @eventmanager.register(EventType.ConfigChanged)
@staticmethod def handle_config_changed(self, event: Event):
def handle_config_changed(event: Event):
if not event: if not event:
return return
event_data: ConfigChangeEventData = event.event_data event_data: ConfigChangeEventData = event.event_data