Compare commits
0
Commits
@@ -30,7 +30,6 @@ logger = logging.getLogger("main")
|
||||
_running = True
|
||||
_pending_lock = threading.Lock()
|
||||
_pending_uids: set[bytes] = set()
|
||||
_processing_uids: set[bytes] = set() # 正在处理（含等待TG发送）的邮件UID
|
||||
|
||||
# Queue 1: raw emails → AI processor
|
||||
_email_queue: queue_module.Queue = queue_module.Queue()
|
||||
@@ -52,8 +51,7 @@ def _email_poller(cfg):
|
||||
if not _running:
|
||||
return
|
||||
with _pending_lock:
|
||||
if mail.uid not in _processing_uids:
|
||||
_processing_uids.add(mail.uid)
|
||||
if mail.uid not in _pending_uids:
|
||||
_pending_uids.add(mail.uid)
|
||||
_email_queue.put((acct_idx, mail))
|
||||
except Exception as e:
|
||||
@@ -92,7 +90,6 @@ def _ai_processor(cfg):
|
||||
# AI 失败也要移除 pending，否则永远卡住
|
||||
with _pending_lock:
|
||||
_pending_uids.discard(mail.uid)
|
||||
_processing_uids.discard(mail.uid)
|
||||
|
||||
time.sleep(0.1 if pending_futures else 0.5)
|
||||
|
||||
@@ -113,7 +110,6 @@ def _tg_worker(cfg):
|
||||
# 发送并标记已读成功后才移除 pending
|
||||
with _pending_lock:
|
||||
_pending_uids.discard(info["uid"])
|
||||
_processing_uids.discard(info["uid"])
|
||||
except queue_module.Empty:
|
||||
break
|
||||
except Exception as e:
|
||||
@@ -122,7 +118,6 @@ def _tg_worker(cfg):
|
||||
try:
|
||||
with _pending_lock:
|
||||
_pending_uids.discard(info["uid"])
|
||||
_processing_uids.discard(info["uid"])
|
||||
except Exception:
|
||||
pass
|
||||
|
||||
|
||||