Simpy中网络信道资源可用状态异常问题求助

你遇到的核心问题是对Simpy资源的概念理解有误，同时呼叫生成的时间逻辑存在错误，以下是具体分析和修复方案：

问题根源 #

1. 资源数概念混淆：network.channel.count代表已被占用的信道数，而非可用数。可用信道数应为network.channel.capacity - network.channel.count，你完全搞反了两者的含义，这是误以为可用数为0的直接原因。
2. 呼叫生成时间逻辑错误：当前代码在模拟时间0时就一次性创建了所有60分钟内的呼叫，没有等待对应时间点执行，导致所有呼叫瞬间抢占资源。
3. 时间单位不一致：join_channel中的呼叫时长以秒为单位（生成值约1-3秒），但呼叫生成逻辑按分钟计算，导致信道占用时间极短，资源状态变化难以跟踪。

修复后的代码 #

import simpy
import numpy as np
import random

class Network(object):
    def __init__(self, env, num_channels):
        self.env = env
        self.channel = simpy.Resource(env, num_channels)

    def join_channel(self, caller):
        # 统一时间单位：将秒转换为分钟
        call_duration = np.random.lognormal(1, .25) / 60  
        yield self.env.timeout(call_duration)  

def start_call(env, caller, network):
    with network.channel.request() as request:          
        yield request                                   
        print(f"Caller {caller}占用信道，当前已用信道数: {network.channel.count}")
        yield env.process(network.join_channel(caller))
        print(f"Caller {caller}释放信道，当前已用信道数: {network.channel.count}")


def run_network(env, num_channels):
    network = Network(env, num_channels)

    # 启动1个测试呼叫
    env.process(start_call(env, "test", network))
    print(f"初始已用信道数: {network.channel.count}，可用信道数: {network.channel.capacity - network.channel.count}")

    call_start_times = (np.random.uniform(0, 60, 600)).astype(int)
    start_time_occurences = []

    for j in range(60): 
        count = np.count_nonzero(call_start_times == j)
        start_time_occurences.append(count)

    current_time = 0
    # 按模拟时间点生成呼叫
    for minute in range(len(start_time_occurences)):
        # 等待到当前分钟
        yield env.timeout(minute - current_time)
        current_time = minute

        caller_count = start_time_occurences[minute]
        if minute == 0:
            print(f"初始化网络，接入{caller_count}个呼叫")
        else:
            print(f"第{minute}分钟，新增{caller_count}个呼叫")
        
        available = network.channel.capacity - network.channel.count
        print(f"当前已用信道数: {network.channel.count}，可用信道数: {available}")
        
        for caller_idx in range(caller_count):
            caller_id = f"{minute}-{caller_idx}"
            if available <= 0:
                print(f"所有信道已满，丢弃呼叫{caller_id}")
            else:
                env.process(start_call(env, caller_id, network))
                available -= 1


if __name__ == '__main__':
    random.seed(42)
    num_channels = 41

    env = simpy.Environment()
    env.process(run_network(env, num_channels))
    env.run(until=100)

关键修改说明 #

• 修正资源数计算逻辑，明确区分已用数和可用数
• 调整呼叫生成逻辑，通过yield env.timeout(minute - current_time)确保在正确的模拟时间点生成呼叫
• 统一时间单位，将呼叫时长从秒转换为分钟（也可选择将呼叫生成时间改为秒，保持一致即可）
• 添加信道占用/释放的日志输出，方便跟踪资源状态变化
• 优化呼叫丢弃判断逻辑，避免因异步进程启动导致的状态判断延迟

内容的提问来源于stack exchange，提问作者superKade