diff --git a/frontends/wechatapp.py b/frontends/wechatapp.py
index 301f10c6..4ceb7e8a 100644
--- a/frontends/wechatapp.py
+++ b/frontends/wechatapp.py
@@ -393,7 +393,9 @@ def _send(show):
         try:
             done = []; turn = 1
             while True:
-                item = dq.get(timeout=300)
+                if _task_aborted.get(uid): break
+                try: item = dq.get(timeout=300)
+                except queue.Empty: continue
                 if 'done' in item: break
                 if item.get('turn', turn) > turn:
                     outputs = item.get('outputs', [])