Jmeter Inter Thread Communicator队列等待无法停止致堆内存耗尽求助

问题原因 #

TG-2持续等待的核心原因是Inter Thread Communicator的「从队列获取」元素默认会无限阻塞，直到队列中有新数据。即使TG-2的运行时长已到，只要该元素仍在等待队列数据，线程就不会终止，最终导致测试挂起、内存耗尽。

解决方案 #

1. 为「从队列获取」设置超时时间 #

在TG-2的「Get from Queue」元素中，找到**Timeout（超时时间）**配置项（单位：毫秒），设置一个合理的值（例如5000，即5秒）。当队列空且超时时间到达后，该元素会停止等待并抛出超时异常（或返回空值，取决于插件配置），此时TG-2的线程可以继续执行后续逻辑，最终在运行时长结束后正常退出。

操作步骤：

• 打开TG-2中的「Get from Queue」元素
• 在「Timeout」字段输入数值（如5000）
• 可选：勾选「Return null on timeout」，让线程获取到空值后自行处理退出逻辑

2. 使用「毒丸」标记终止TG-2 #

当TG-1运行结束时，向队列Q1中放入一个特殊的「终止标记」（比如字符串"STOP_PROCESSING"）。TG-2在每次从队列获取数据后，先检查是否为该标记：

• 如果是，立即退出循环或停止线程
• 如果不是，正常处理业务逻辑

实现步骤：

• 在TG-1的最后添加一个「Put to Queue」元素，将"STOP_PROCESSING"放入Q1
• 在TG-2中，获取队列数据后添加一个「If Controller」，判断${__jexl3(${queueData} == "STOP_PROCESSING",)}
• 在If Controller下添加一个「Stop Thread」元素（选择「Current Thread」），触发线程终止

3. 结合线程组状态控制TG-2循环 #

通过JMeter属性跟踪TG-1的运行状态，让TG-2仅在TG-1运行中或队列非空时继续处理：

• 在TG-1的「Setup Thread Group」中设置属性：${__setProperty(tg1.running, true,)}
• 在TG-1的「Teardown Thread Group」中更新属性：${__setProperty(tg1.running, false,)}
• 在TG-2中使用「While Controller」，条件设置为：${__jexl3(${__property(tg1.running)} == "true" || ${__javaScript(ctx.getThreadGroup().getSamplerContext().get("queueSize") > 0,)},)}
• 当TG-1停止且队列空时，While Controller会退出循环，TG-2线程正常结束

额外注意事项 #

• 确保TG-2的线程数与处理能力匹配，避免队列积压
• 定期监控队列大小，防止内存溢出
• 若使用超时方案，需处理超时后的逻辑（如跳过空数据、记录日志）

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