在单独的线程中运行asyncio循环，从和到循环发出信号

import asyncio
import threading

def start_asyncio_loop():
    asyncio.set_event_loop(asyncio.new_event_loop())
    asyncio.get_event_loop().run_forever()

thread = threading.Thread(target=start_asyncio_loop)
thread.start()

# 创建一个Queue对象
queue = asyncio.Queue()

# 向asyncio循环发送信号的函数
def send_signal():
    asyncio.run_coroutine_threadsafe(queue.put(None), asyncio.get_event_loop())

# 在主线程中调用send_signal()函数来发送信号
send_signal()

async def process_signal():
    while True:
        await queue.get()
        # 执行相应的操作

# 在asyncio循环中运行process_signal()函数
asyncio.get_event_loop().run_until_complete(process_signal())