C接口实现Task等待功能#

需求#

很多情况下，我们需要实现这样的功能：

调用接口，但是结果需要等一段时间才会返回
等待获取结果的途中，我们希望其他任务也能继续运行，不阻塞住整个系统
使用订阅topic的方式，不好记，很麻烦且不优雅

为了解决这个问题，可以对你的c接口实现Task等待功能，实现之后，即可在等待数据返回的途中，允许其他任务继续运行，不阻塞整个系统。

用户使用#

提供给用户的调用方法，参考如下的演示代码（只是演示功能，实际目前还没这个接口）

--任务内等待结果
sys.taskInit(function()
    local data,result,header = http.taskGet("http://xxxxxxxxx").wait()
    log.info("http get",data,result,header)
end)

--等待回调函数
http.taskGet("http://xxxxxxxxx").cb(function(data,result,header)
    log.info("http get",data,result,header)
end)

接口按命名规范，以task开头。

调用后的返回值的wait下标为一个闭包，可实现多任务内非阻塞的等待功能。
调用后的返回值的cb下标为一个回调器，传入function可实现异步回调功能。

C接口适配#

新建可等待对象#

在c接口中，可以使用luat_pushcwait函数，获取一个可等待对象，并将其放置在栈顶，最后返回用户即可。

同时该函数会返回一个64位的id，用于之后发布等待结束的消息。

static int l_xxxx_block(lua_State *L) {
    uint64_t id = luat_pushcwait(L);//获取等待对象放到栈顶，并获取其id
    //什么回调函数配置的巴拉巴拉
    //.....
    //.....
    return 1;//把生成的等待对象返回出去以供lua调用
}

如果只想返回一个失败结果（如初始化失败的情况），则可以直接返回一个只会返回错误结果的可等待对象

该对象会在等待时即时返回给定的错误返回值，并且不会返回等待id，无需再发布消息

static int l_xxxx_block(lua_State *L) {
    int initial = xxxxx(xxx);
    if(!initial)//如果初始化失败
    {
        lua_pushnil(L);//第一个返回值
        lua_pushstring(L,"失败原因巴拉巴拉");//可以多加几个返回值
        luat_pushcwait_error(L,2);//两个返回值，所以传入2
        return 1;//把生成的等待对象返回出去以供lua调用
    }
    //正常情况的处理巴拉巴拉
    //.....
    //.....
}

print(xxx.xxxxxBlock().wait())
--如果走到上面代码的失败处理部分，就会直接返回：
--nil  失败原因巴拉巴拉

发布等待结束的消息#

只要知道发起等待时，获取的唯一id，即可在后面停止等待。

如果没有返回值#

只需调用luat_cbcwait_noarg函数，传入id即可

static int l_xxxx_cb(uint64_t id) {
    luat_cbcwait_noarg(id);
}

或者调用luat_cbcwait函数也可以（在函数内有lua栈时）

static int timer_handler(lua_State *L, void* ptr) {
    luat_timer_t *timer = (luat_timer_t *)ptr;
    uint64_t* idp = (uint64_t*)timer->id;
    luat_cbcwait(L, *idp, 0); //表示这个回调有0个返回值
    return 0;
}

如果函数有返回值#

先将需要返回的参数推入lua栈，然后调用luat_cbcwait函数，传入id即可

static int timer_handler(lua_State *L, void* ptr) {
    luat_timer_t *timer = (luat_timer_t *)ptr;
    uint64_t* idp = (uint64_t*)timer->id;
    lua_pushstring(L,"这是演示的返回值");
    lua_pushstring(L,"这是演示的第二个返回值");
    luat_cbcwait(L, *idp, 2); //表示这个回调有2个返回值
    return 0;
}