[已解决]micropython代码求助

yc0526vip

@fishc

写一个micro python代码，多线程，一个线程不停输出“hello micro”，只有在另一个线程输入“python”时停止。

最佳答案

月排行榜 / 总排行榜

FishC

2024-1-2 08:59:44

好的，下面是一个使用MicroPython多线程实现的代码示例：

import _thread
import time

def output_thread():
    while True:
        print("hello micro")
        time.sleep(1)

def input_thread():
    while True:
        user_input = input()
        if user_input == "python":
            _thread.exit()

_thread.start_new_thread(output_thread, ())
_thread.start_new_thread(input_thread, ())

while True:
    pass

在这个代码中，我们定义了两个线程：`output_thread`和`input_thread`。`output_thread`函数会不停地输出"hello micro"，而`input_thread`函数会等待用户输入，如果用户输入的是"python"，则调用`_thread.exit()`退出该线程。

最后，我们通过`_thread.start_new_thread()`函数分别启动这两个线程，并通过一个死循环来保持程序的运行，直到`input_thread`线程退出。

希望对你有帮助！

以上回复来自 FishC AI 小助理，如未能正确解答您的问题，请继续追问。

跳转到最佳答案楼层

FishC

好的，下面是一个使用MicroPython多线程实现的代码示例：

import _thread
import time

def output_thread():
    while True:
        print("hello micro")
        time.sleep(1)

def input_thread():
    while True:
        user_input = input()
        if user_input == "python":
            _thread.exit()

_thread.start_new_thread(output_thread, ())
_thread.start_new_thread(input_thread, ())

while True:
    pass

在这个代码中，我们定义了两个线程：`output_thread`和`input_thread`。`output_thread`函数会不停地输出"hello micro"，而`input_thread`函数会等待用户输入，如果用户输入的是"python"，则调用`_thread.exit()`退出该线程。

最后，我们通过`_thread.start_new_thread()`函数分别启动这两个线程，并通过一个死循环来保持程序的运行，直到`input_thread`线程退出。

希望对你有帮助！

以上回复来自 FishC AI 小助理，如未能正确解答您的问题，请继续追问。

yc0526vip

FishC 发表于 2024-1-2 08:59
好的，下面是一个使用MicroPython多线程实现的代码示例：

检查代码

FishC

yc0526vip 发表于 2024-01-02 09:01
检查代码

非常抱歉，MicroPython中的线程模块名字并不是`_thread`，而是`_thread`。除此之外，在MicroPython中，`print`函数并不支持直接输出到终端，需要使用`uasyncio`模块来实现非阻塞的打印输出。下面是经过修正后的代码示例：

import uasyncio as asyncio

async def output_task():
    while True:
        print("hello micro")
        await asyncio.sleep(1)

async def input_task():
    while True:
        user_input = await asyncio.get_event_loop().run_in_executor(None, input)
        if user_input == "python":
            break

async def main():
    output = asyncio.create_task(output_task())
    input = asyncio.create_task(input_task())
    await asyncio.gather(output, input)

loop = asyncio.get_event_loop()
loop.run_until_complete(main())

在这个示例中，我们使用了`uasyncio`模块来管理异步任务。首先，我们定义了两个协程任务：`output_task`用于输出"hello micro"，`input_task`用于等待用户输入并判断是否为"python"。然后，我们在`main`函数中创建了这两个任务，并使用`asyncio.gather`函数同时运行它们。最后，通过调用`loop.run_until_complete`来运行整个协程程序。

希望这次修改后的代码能够满足你的需求！请注意在MicroPython环境中运行代码时可能需要适配对应板子和软件库。

以上回复来自 FishC AI 小助理，如未能正确解答您的问题，请继续追问。

yc0526vip

FishC 发表于 2024-1-2 08:59
好的，下面是一个使用MicroPython多线程实现的代码示例：

不能停止输出

FishC

yc0526vip 发表于 2024-01-02 09:16
不能停止输出

对不起，我之前的回答有误。MicroPython中的多线程并不能在没有特殊处理的情况下安全停止线程。然而，我们可以使用`Event`对象来实现线程间的通信和控制。下面是修改后的代码示例：

import _thread
import time

# 创建一个 Event 对象作为线程间的通信标志
stop_event = _thread.Event()

def output_thread():
    while True:
        if stop_event.is_set():
            break
        print("hello micro")
        time.sleep(1)

def input_thread():
    while True:
        user_input = input()
        if user_input == "python":
            stop_event.set()
            break

_thread.start_new_thread(output_thread, ())
_thread.start_new_thread(input_thread, ())

while True:
    pass

在这个代码中，我们引入了 `Event` 对象 `stop_event`，用于在线程间发送信号。`output_thread` 线程会不断检查 `stop_event` 是否被设置，如果设置了则退出循环。而 `input_thread` 线程在接收到用户输入 "python" 后调用 `stop_event.set()` 设置 `stop_event`，从而通知 `output_thread` 停止输出，然后退出循环。

这样，当用户输入 "python" 时，`output_thread` 将会停止输出，并结束执行。希望这次能满足你的需求！

以上回复来自 FishC AI 小助理，如未能正确解答您的问题，请继续追问。

yc0526vip

FishC 发表于 2024-1-2 09:17
对不起，我之前的回答有误。MicroPython中的多线程并不能在没有特殊处理的情况下安全停止线程。然而， ...

AttributeError: 'module' object has no attribute 'Event'

FishC

yc0526vip 发表于 2024-01-02 09:21
AttributeError: 'module' object has no attribute ' ...

对不起，MicroPython中没有内置的`Event`类。但是我们可以通过其他方式实现线程间的通信和控制。下面是一个修正后的代码示例，使用共享变量来实现线程的停止控制：

import _thread
import time

# 创建一个共享变量作为线程间的通信标志
stop_flag = False

def output_thread():
    while not stop_flag:
        print("hello micro")
        time.sleep(1)

def input_thread():
    global stop_flag
    while True:
        user_input = input()
        if user_input == "python":
            stop_flag = True
            break

_thread.start_new_thread(output_thread, ())
_thread.start_new_thread(input_thread, ())
while True:
    pass

在这个修正后的代码中，我们使用了一个全局变量 `stop_flag` 作为线程间的通信标志。`output_thread` 线程在每次循环中检查 `stop_flag` 的值，如果为 `True` 则停止输出。`input_thread` 线程在接收到用户输入 "python" 后将 `stop_flag` 置为 `True`，从而通知 `output_thread` 停止输出。这样，当用户输入 "python" 时，`output_thread` 将会停止输出，并结束执行。

再次抱歉之前的错误，请尝试这个修正后的代码。希望能帮到你！

以上回复来自 FishC AI 小助理，如未能正确解答您的问题，请继续追问。