threading模块的threading.Event方法_模拟红绿灯程序

本程序参考链接https://www.cnblogs.com/chengd/articles/7770898.html

在学习查阅别人的代码时，对threading.Event有疑问，认真研究了一下下，故记录下来

以下为个人理解，如有不恰当的地方，欢迎指出来，谢谢

 

 

Python threading模块提供Event对象用于线程间通信。用于主线程控制其他线程的执行，事件主要提供了四个方法wait、clear、set、isSet

• set()：可设置Event对象内部的信号标志为True
• clear()：可清除Event对象内部的信号标志为False
• isSet()：Event对象提供了isSet()方法来判断内部的信号标志的状态。当使用set()后，isSet()方法返回True；当使用clear()后，isSet()方法返回False
• wait()：该方法只有在内部信号为True的时候才会被执行并完成返回。当内部信号标志为False时，则wait()一直等待到其为True时才返回

通过Event来实现一个红绿灯例子，

即启动一个线程做交通指挥灯，生成几个线程做汽车，汽车行驶按照红灯停绿灯行的规则

#cherry_cui


import threading, time                            # 导入所需的模块
import random


def light():                                      # 定义light函数
    if not event.isSet():
        event.set()                                # 初始化isSet()为True：若isSet为True，不执行set()；若isSet为False，执行set()
    count = 0
    while True:
        if count < 10:
            print('\033[42;1m---green light on---\033[0m')
        elif count < 13:
            print('\033[43;1m---yellow light on---\033[0m')
        elif count < 20:
            if event.isSet():                     # 若isSet()为True，执行clear()，isSet()返回False
                event.clear()
            print('\033[41;1m---red light on---\033[0m')
        else:
            count = 0
            event.set()                            # 打开绿灯
        time.sleep(1)                              # 休眠1s才能让car()有机会获取CPU的执行权
        count += 1


def car(n):                                       # 定义car函数
    while 1:
        time.sleep(random.randrange(3, 10))       # 休眠3s到10s（随机）才能让light()有机会获取CPU的执行权
        print(event.isSet())                      # 打印当前light()中isSet的状态
        if event.isSet():                         # 获取light()中isSet的状态，若为True则执行下一个语句
            print("car [%s] is running..." % n)
        else:
            print('car [%s] is waiting for the red light...' % n)  # event.wait()    #红灯状态下调用wait方法阻塞，汽车等待状态


if __name__ == '__main__':
    car_list = ['aa', 'bb', 'cc']                # 定义car数组
    event = threading.Event()                     # 通过threading.Event()生成一个event对象和对象的引用event

    Light = threading.Thread(target=light)        # 创建一个以light为目标的线程任务
    Light.start()                                 # 启动Light线程

    for i in car_list:                            # 遍历car数组
        t = threading.Thread(target=car, args=(i,))                    # 创建一个以car方法的线程任务，传car数组的数据给car()
        t.start()                                  # 启动t线程

 

 运行结果：

 

 在本程序中，新学习到的地方，记录如下：

 

• Python输出文字颜色的设置

 

 

• Python标准库 threading.Thread

使用Thread类创建线程

t = threading.Thread(target=car, args=(i,))
t.start()　　

t= Thread(target=function_name, args=(function_parameter1, function_parameterN))

 

function_name：需要线程去执行的方法名

args：线程执行方法接收的参数，该属性是一个元组，若只有一个参数则需要在末尾加逗号

start()：为启动进程