一. _thread - 多线程

_thread 模块提供创建新线程的方法，并提供互斥锁, 线程最多16个

import _thread

1. 举例一: 简单的多线程并行

import _thread
import utime

counter = 0

def led_func():
  while True:
    print("这是一个LED闪灯程序, 我在每2秒疯狂闪灯!进程号",_thread.get_ident())
    utime.sleep(2)

def add1_persecond():
  while True:
    global counter
    counter += 1
    print("计数加一:",counter,",进程号:",_thread.get_ident())
    utime.sleep(1)
  

if __name__ == "__main__":
  _thread.start_new_thread(led_func,())
  _thread.start_new_thread(add1_persecond,())

2. 带参数的进程创建

带参数创建进程要注意: 参数必须传元组, 所以如果你只有一个参数a, 也应该包裹在元组中 (a,), 如果不需要参数则传递空元组()

import _thread
import utime

counter = 100

def add_thread(step):
  while True:
    global counter
    counter += step
    print("计数:",counter,",进程号:",_thread.get_ident())
    utime.sleep(1)
    
if __name__ == "__main__":
  _thread.start_new_thread(add_thread,(3,))

3. 举例三: 互斥锁

add10_persecond的for循环操作counter时, 避免minus5_persecond的for循环操作它, 所以加个互斥锁, 每个进程, 拿到这个锁才能操作公共变量counter

import _thread
import utime

lock = _thread.allocate_lock() #创建一个互斥锁

counter = 0

def led_func():
  while True:
    print("这是一个LED闪灯程序, 我在每2秒疯狂闪灯!进程号",_thread.get_ident())
    utime.sleep(2)

def add10_persecond():
  while True:
    lock.acquire()
    global counter
    for i in range(10):
      counter += 1
      print("计数加一:",counter,",进程号:",_thread.get_ident())
    lock.release()
    utime.sleep(1)
    
def minus5_persecond():
    while True:
      lock.acquire()  
      global counter
      for i in range(5):
        counter -= 1
        print("计数减一:",counter,",进程号:",_thread.get_ident())
      lock.release()
      utime.sleep(5)
      

if __name__ == "__main__":
  _thread.start_new_thread(led_func,())
  _thread.start_new_thread(add10_persecond,())
  _thread.start_new_thread(minus5_persecond,())

4. 线程退出

暂时没有提供类似于 join 函数之类的操作， 前期可以使用一个全局的标志位来标志线程的退出。
说白了就是: 如果线程中有while, 需要打破while循环,用以达到退出效果

import _thread
import utime

counter = 0

def led_func():
  global counter
  while counter<20:
    print("这是一个LED闪灯程序, 我在每2秒疯狂闪灯!进程号",_thread.get_ident())
    utime.sleep(2)

def add1_persecond():
  while True:
    global counter
    counter += 1
    print("计数加一:",counter,",进程号:",_thread.get_ident())
    utime.sleep(1)

if __name__ == "__main__":
  _thread.start_new_thread(led_func,())
  _thread.start_new_thread(add1_persecond,())

二. uio - 输入输出流

uio 模块包含其他类型的stream（类文件）对象和辅助函数。

import uio

1. 打开文件

fd = uio.open(name, mode=’r’, **kwarg)

参数:

• name ：文件名
• mode ：打开模式 r : 只读模式打开文件, w 写入模式打开文件，每次写入会覆盖上次写入数据,a 只写追加模式打开文件，可连续写入文件数据而不是覆盖数据
• **kwarg：可变长参数列表

2. 关闭打开的文件

fd.close()

我们得到的文档流该怎么操作呢?? 详见: 第三节 : 文件和操作系统

三. 文件操作

1. read() 读文件对象

import uio
file = uio.open("/usr/test.txt",'r')
txt = file.read()
print(txt)

2. write() 写文件对象

写文件对象, 有 w 和 a 两种模式, 返回写入的字节数

import uio
file = uio.open("/usr/test.txt",'a')
file.write("好诗,好诗呀!")
print(txt)

四. gc - 内存碎片回收

gc 模块实现内存垃圾回收机制，该模块实现了CPython模块相应模块的子集。

import gc