micropython-ESP32 rtos 示例

以下是一个简单的 Micropython-ESP32 RTOS 示例，它使用 uasyncio 模块创建两个协程，一个协程定期打印消息，另一个协程等待用户输入并回显输入的内容。

import uasyncio as asyncio

async def print_message():
    while True:
        print("Hello from print_message!")
        await asyncio.sleep(1)

async def input_handler():
    while True:
        data = await asyncio.get_event_loop().run_in_executor(None, input)
        print("You entered:", data)

loop = asyncio.get_event_loop()
loop.create_task(print_message())
loop.create_task(input_handler())
loop.run_forever()

在这个示例中，`print_message()` 协程每秒打印一次消息，而 `input_handler()` 协程等待用户输入并回显输入的内容。`create_task()` 方法用于将这两个协程添加到事件循环中，`run_forever()` 方法则启动事件循环并让所有协程运行起来。

此外，您还可以使用 uqueue 模块创建一个队列对象，用于在多个任务之间传递数据。下面是一个示例，使用队列实现两个任务之间的通信：

import uasyncio as asyncio
import uqueue

q = uqueue.Queue(maxsize=1)

async def producer():
    while True:
        data = b"Hello from producer!"
        await q.put(data)
        await asyncio.sleep(1)

async def consumer():
    while True:
        data = await q.get()
        print("Received from producer:", data)

loop = asyncio.get_event_loop()
loop.create_task(producer())
loop.create_task(consumer())
loop.run_forever()

在这个示例中，`producer()` 协程每秒向队列中添加一个字符串，而 `consumer()` 协程从队列中读取数据并打印出来。由于队列的最大容量为 1，因此 `producer()` 协程在放置新的数据之前必须等待 `consumer()` 协程读取队列中的数据。