【学习笔记】SimPy 学习（二）：进程交互

import simpy

# 定义一个汽车进程
def car(env):
    while True:
        print('Start parking at %d' % env.now)
        parking_duration = 5
        # 进程延时 5s
        yield env.timeout(parking_duration) 
        print('Start driving at %d' % env.now)
        trip_duration = 2
        # 延时 2s
        yield env.timeout(trip_duration) 

# 仿真启动
env = simpy.Environment()   # 实例化环境
env.process(car(env))   # 添加汽车进程
env.run(until = 15)   # 设定仿真结束条件, 这里是 15s 后停止

import simpy

from random import seed, randint
seed(23)

class ENV:
    def __init__(self, env):
        self.env = env
        self.drive_proc = env.process(self.drive(env))
        self.bat_ctrl_proc = env.process(self.bat_ctrl(env))
        print("执行了 2 个 process")
        self.bat_ctrl_reactivate = env.event()
        self.bat_ctrl_sleep = env.event()
        print("创建了 2 个事件")

    # 驾驶进程
    def drive(self, env):
        while True:
            # drive 20~40 minutes
            print("Start driving at: ", env.now)
            print("drive() 抛出了 timeout")
            yield env.timeout(randint(20, 40))
            print("drive() 恢复了")
            print("End driving at: ", env.now)

            # parking 1~6 hours
            print("Start parking at: ", env.now)
            # activate battery charging
            # 这段代码应该是指触发事件并成功
            print("drive() 触发了 reactivate 并成功")
            self.bat_ctrl_reactivate.succeed()
            self.bat_ctrl_reactivate =  env.event()
            # 继续执行
            # 超时并挂起，等待 bat_ctrl_sleep 事件发生
            print("drive() 抛出了 timeout 和 sleep")
            yield env.timeout(randint(60, 360)) & self.bat_ctrl_sleep
            print("drive() 恢复了")
            print("End parking at: ", env.now)

    # 电池充电进程
    def bat_ctrl(self, env):
        while True:
            print("Charge sleep at: ", env.now)
            # 挂起。接收到 drive() 中的事件发生后恢复
            print("bat_ctrl() 抛出了 reactivate")
            yield self.bat_ctrl_reactivate
            print("bat_ctrl() 恢复了")
            print("Charge activate at: ", env.now)
            print("bat_ctrl() 抛出了 timeout")
            yield env.timeout(randint(30, 90))
            print("bat_ctrl() 恢复了")
            print("Charge end at:", env.now)
            # 这段代码应该是指触发事件并成功
            print("bat_ctrl() 触发了 sleep 并成功")
            self.bat_ctrl_sleep.succeed()
            self.bat_ctrl_sleep = env.event()


if __name__ == "__main__":
    env = simpy.Environment()
    # 下面这一步执行了 init()
    ENV(env)
    print("env 开始模拟...")
    env.run(until=300)

from random import seed, randint
 
import simpy
seed(23)
 
class EV:
    def __init__(self, env):
        self.env = env
        self.drive_proc = env.process(self.drive(env))
 
 
    def drive(self, env):
        while True:
            # 行驶20-40分钟
            yield env.timeout(randint(20, 40))
 
            # 停车1小时
            print('开始停车时间', env.now)
            charging = env.process(self.bat_ctrl(env))
            print("设置了 timeout")
            parking = env.timeout(60)
            print("抛出了事件")
            yield charging | parking
            if not charging.triggered:
                # 中断充电
                charging.interrupt('该出发了！')
            print('结束停车时间：', env.now)
            
              
    def bat_ctrl(self, env):
        print('充电器启动时间：', env.now)
        try:
            yield env.timeout(randint(60, 90))
            print('充电器完成时间：', env.now)
        except simpy.Interrupt as i:
            # 充电被中断
            print('充电器中断时间：', env.now, ', msg:', i.cause)        
        
env = simpy.Environment()
ev = EV(env)
env.run(until=100)