def __init__(self):
	self.running = True
	self.notification_queue = Queue()
	self.loop = asyncio.new_event_loop()

	# 1. 先啟動一個純粹運行事件循環(huán)的后臺線程
	self.loop_thread = threading.Thread(target=self._run_event_loop, daemon=True)
	self.loop_thread.start()

	# 2. 啟動你的隊列監(jiān)聽線程
	self.process_thread = threading.Thread(target=self._process_notifications, daemon=True)
	self.process_thread.start()

def _run_event_loop(self):
	"""專門負責運行 asyncio 循環(huán)的線程"""
	asyncio.set_event_loop(self.loop)
	self.loop.run_forever()

def _process_notifications(self):
	"""處理隊列，將任務(wù)提交給已經(jīng)運行的 loop"""
	while self.running:
		try:
			# 獲取隊列中的數(shù)據(jù)（同步阻塞）
			notification = self.notification_queue.get(timeout=1)

			# 關(guān)鍵：將協(xié)程任務(wù)提交給正在運行的 self.loop
			asyncio.run_coroutine_threadsafe(
				self._show_notification(notification),
				self.loop
			)
		except Exception: # 隊列為空超時
			continue

async def _show_notification(self, data):
	"""真正的異步發(fā)送邏輯"""
	# 這里調(diào)用 desktop_notifier.send(...)
	print(f"正在發(fā)送通知: {data}")

from desktop_notifier.common import Button
# 嘗試使用desktop-notifier顯示通知
await self.notifier.send(
    title=title,
    message=message,
    urgency=Urgency.Critical if priority == 'high' else Urgency.Normal,
    on_clicked=lambda: on_click(),
    timeout=0  # 0表示通知常駐
)

def on_click():
    print("用戶點擊了通知，準備喚醒窗口...")
    # 關(guān)鍵判斷：確保窗口實例存在且未被銷毀
    if backend.globals.window:
        try:
            # 1. 從最小化恢復
            backend.globals.window.restore
            # 2. 提到最前顯示（如果之前是 hide 狀態(tài)）
            backend.globals.window.show
            # 3. 某些平臺下可能需要額外聚焦
            backend.globals.window.focus
            # Windows部分系統(tǒng)需要強制處理下
            hwnd = win32gui.FindWindow(None, "TodoList")
            if hwnd:
                # 恢復窗口（如果最小化）
                win32gui.ShowWindow(hwnd, win32con.SW_RESTORE)
                # 強制推至前臺
                win32gui.SetForegroundWindow(hwnd)
        except Exception as e:
            print(f"喚醒失敗，窗口可能已關(guān)閉: {e}")
    else:
        print("錯誤：找不到窗口實例！")