如何在Karate框架中执行异步Feature测试调用？

问题场景 #

需要运行一个耗时较长的API调用，随后通过另一个API调用终止它，但尝试的几种异步实现方式均失败：

尝试方法1：JS异步函数 #

* def longQuery = async function() { karate.call('this:submit-long-running-sync-query.feature', {queryID: queryID})}
* karate.eval(longQuery())

问题：未真正实现异步执行，仅在超时后返回结果

尝试方法2：转换JS函数到Java线程 #

* def longQuery = function() { karate.call('this:submit-long-running-sync-query.feature', {queryID: queryID})}
* eval new java.lang.Thread(karate.toJava(longQuery)).start()

报错信息：com.intuit.karate.KarateException: The value 'DynamicObject<JSFunction>@4bc59b27' cannot be passed from one context to another.

尝试方法3：直接传入JS函数到Java线程 #

* def longQuery = function() { karate.call('this:submit-long-running-sync-query.feature', {queryID: queryIDtest})}
* eval new java.lang.Thread(longQuery).start()

报错信息：java.lang.IllegalStateException: Multi threaded access requested by thread Thread[Thread-1,5,main] but is not allowed for language(s) js

可行解决方案 #

方案1：使用Karate内置karate.fork()（官方推荐） #

Karate提供了专门的karate.fork()方法处理异步执行，会返回Future对象用于后续结果获取或任务控制，自动规避线程上下文冲突：

# 异步启动长耗时查询Feature
* def queryFuture = karate.fork('this:submit-long-running-sync-query.feature', {queryID: queryID})

# 立即执行终止API调用
* call('this:terminate-query.feature', {queryID: queryID})

# 可选：等待异步任务完成并获取结果
* def queryResult = queryFuture.get()

方案2：Java类封装+线程池执行 #

如果需要更灵活的线程调度，可以将Feature调用逻辑封装到Java类中，避免直接传递JS函数：

1. 创建Java工具类（示例：QueryRunner.java）

package com.your.package;

import com.intuit.karate.Runner;
import java.util.Map;

public class QueryRunner implements Runnable {
    private final String featurePath;
    private final Map<String, Object> params;

    public QueryRunner(String featurePath, Map<String, Object> params) {
        this.featurePath = featurePath;
        this.params = params;
    }

    @Override
    public void run() {
        Runner.path(featurePath).params(params).parallel(1);
    }
}

2. 在Karate Feature中调用

* def runner = new com.your.package.QueryRunner('this:submit-long-running-sync-query.feature', {queryID: queryID})
* eval java.util.concurrent.Executors.newSingleThreadExecutor().submit(runner)

# 执行终止API
* call('this:terminate-query.feature', {queryID: queryID})

核心注意事项 #

• 禁止在异步线程中直接调用Karate的JS上下文相关API，JS引擎不支持多线程并发访问
• 使用karate.fork()时，仅传递字符串、数字等可序列化简单参数，避免复杂对象跨线程传递

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