我正在研究如何取消当前的ws.recv() ...我看到了所有三个停止，但从来没有接收停止。

您的 receive 协程可能会挂起，等待一些数据到达，因此它无法检查 keep_running 标志。

停止正在运行的协程的简单而强大的方法是 cancel 驱动它的异步 Task 。这将立即取消暂停协程，并生成它正在等待的 CancelledError 。当使用cancel时，你根本不需要 keep_running 标志，异常将自动终止循环。

对.start()的调用创建了一个帮助线程来启动异步事件循环。

这是可行的，但是您并不真的需要为每个 PyAlmondPlus 实例创建一个新的线程和一个全新的事件循环。Asyncio被设计为在单个线程内运行，因此一个事件循环实例可以承载任意数量的协程。

这是一个可能的设计，实现了这两个想法(没有用实际的web套接字测试)：

# pre-start a single thread that runs the asyncio event loop
bgloop = asyncio.new_event_loop()
_thread = threading.Thread(target=bgloop.run_forever)
_thread.daemon = True
_thread.start()
class PyAlmondPlus:
    def __init__(self, api_url):
        self.api_url = api_url
        self.ws = None
    async def connect(self):
        if self.ws is None:
            self.ws = await websockets.connect(self.api_url)
    async def receive(self):
        # keep_running is not needed - cancel the task instead
        while True:
            if self.ws is None:
                await self.connect()
            recv_data = await self.ws.recv()
    async def init_receive_task(self):
        self.receive_task = bgloop.create_task(self.receive())
    def start(self):
        # use run_coroutine_threadsafe to safely submit a coroutine
        # to the event loop running in a different thread
        init_done = asyncio.run_coroutine_threadsafe(
            self.init_receive_task(), bgloop)
        # wait for the init coroutine to actually finish
        init_done.result()