quecpython 主线程while循环中调用的MainThread类Run,并在主线程中运行多个子线程Run进行业务运行。创建的定时器的触发也不需要等待主线程和子线程的业务结束,非阻塞。写个示例代码
时间: 2024-03-27 16:40:07 浏览: 65
好的,以下是一个简单的示例代码,展示了如何使用QuecPython创建一个定时器,同时在主线程中运行多个子线程进行业务运行,并且定时器触发不会阻塞主线程和子线程的执行:
```python
import utime
import _thread
class MainThread:
def __init__(self):
# 创建定时器,每隔1秒触发一次
self.timer = Timer(1, self.timer_callback)
self.timer.start()
def run(self):
# 主线程while循环
while True:
# 进行业务操作
print("MainThread is running")
utime.sleep(2)
def timer_callback(self):
# 定时器回调函数
print("Timer is triggered")
def sub_thread(thread_name):
# 子线程运行函数
while True:
# 进行业务操作
print("SubThread %s is running" % thread_name)
utime.sleep(3)
# 创建主线程对象
main_thread = MainThread()
# 启动多个子线程
for i in range(3):
_thread.start_new_thread(sub_thread, ("Thread-%d" % i,))
# 运行主线程
main_thread.run()
```
在上述示例代码中,我们创建了一个名为`MainThread`的类,其中包含了一个定时器和一个`run`方法,该方法中包含了主线程的业务逻辑,并且在循环中每隔2秒打印一次日志。
同时,我们使用`_thread`模块创建了3个子线程,每个子线程运行一个名为`sub_thread`的函数,该函数中包含了子线程的业务逻辑,并且在循环中每隔3秒打印一次日志。
最后,我们在代码的最后一行调用了`MainThread`对象的`run`方法,启动了主线程,并且定时器的回调函数每隔1秒被触发一次,但不会阻塞主线程和子线程的执行。
阅读全文