JMeter跨线程通信插件FifoTimeout配置不生效及线程组阻塞求助

同类问题确认 #

确实有不少JMeter用户遇到过Inter Thread Communicator插件的这个阻塞问题：当生产者线程组停止生成数据后，消费者线程组的取队列操作会无限等待，即使设置了全局超时配置也可能不生效，最终导致测试无法正常终止、资源耗尽。

原配置未生效的可能原因 #

1. 配置参数名错误：部分插件版本中，超时参数名并非kg.apc.jmeter.functions.FifoTimeout，可尝试改为interthread.communicator.fifo.timeout后重启JMeter。
2. 未显式指定超时：全局配置可能未被__fifoGet函数读取，可直接在函数中显式设置超时，比如__fifoGet("Q1", 120)，表示等待120秒后超时返回空。
3. 插件版本兼容问题：如果使用的是较旧版本的插件，建议升级到最新稳定版后再测试。

替代方案 #

方案1：使用Groovy+Java并发队列实现线程间通信 #

这是最灵活且原生的实现方式，无需依赖第三方插件：

• 初始化队列与状态标志：在测试计划最顶部添加一个JSR223 Sampler（仅执行一次），代码如下：

// 初始化线程安全队列
props.put("idQueue", new java.util.concurrent.LinkedBlockingQueue<String>())
// 标记生产者是否在运行
props.put("producerActive", true)

• 生产者线程组（TG-1）存数据：生成ID后，用JSR223 Sampler将ID存入队列：

def queue = props.get("idQueue")
// 假设generatedId是你生成的ID变量
queue.put(vars.get("generatedId"))

• 生产者停止时更新状态：在TG-1的最后添加一个JSR223 Sampler，设置状态为停止：

props.put("producerActive", false)

• 消费者线程组（TG-2）取数据：用JSR223 Sampler实现带超时的取数逻辑，同时判断是否需要停止：

def queue = props.get("idQueue")
def producerActive = props.get("producerActive")

// 尝试10秒内获取数据，超时返回null
def id = queue.poll(10, java.util.concurrent.TimeUnit.SECONDS)

if (id != null) {
    // 将获取到的ID存入变量，供后续取样器使用
    vars.put("currentId", id)
} else {
    // 超时后检查：生产者已停止且队列为空，停止当前线程组
    if (!producerActive && queue.isEmpty()) {
        ctx.getThreadGroup().stop()
    }
}

方案2：使用JMeter原生的文件式线程间通信 #

JMeter本身提供了基于文件的线程间通信方式，通过__FileWrite和__FileRead函数结合临时文件实现：

• TG-1生成ID后，用__FileWrite将ID写入临时文件，每行一个ID。
• TG-2用__FileRead读取文件中的ID，同时设置读取超时，当文件不再更新且无内容可读时，通过Flow Control Action停止线程组。
  注意：这种方式性能略低于内存队列，适合数据量不大的场景。

方案3：控制线程组执行顺序 #

如果允许TG-2在TG-1完全执行完后再启动，可以开启Test Plan的Run thread groups consecutively选项，让TG-1执行完毕后再启动TG-2。此时TG-2只需处理队列中所有数据即可，无需等待新数据，自然不会出现无限阻塞的情况。

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