Tarantool如何处理光纤外的lua错误

Question

我想知道，我怎么能设置回调光纤错误抛出。

例子：

local fiber = require("fiber")
local status = 0 --in my case stored in db

local function time_consuming()
    lua_error
    status = 0
end

function external_api_function()
    if status == 1 then return "already running" end

    status = 1
    fiber.create(time_consuming)
    return "started"
end

我考虑在下次api访问时检查光纤：状态。或者创建一个光纤看门狗，如果我想要状态是有效的。这对我有用，但似乎不是最好的解决方案。

Answer 1

有多种方法可以实现你的目标。

在您的示例中，两条光纤（main和time\u consumingtask）共享相同的作用域-status变量。如果更改子光纤中status变量的值，则父光纤将看到更新。您可以使用简单的代码段来检查这一点：

status = 1
fiber.create(function() status = 0 end)
print(status) -- 0

现在，要捕获异常，请使用pcall函数。它接受一个函数作为第一个参数，调用它并在一个或多个函数结果后返回状态作为第一个值。如果要分析捕获的错误，还可以使用xpcall函数。它将错误处理程序作为第二个参数。

使用pcall您可以更改耗时的功能，如下所示：

local function time_consuming()
    local ok = pcall(function() lua_error end)
    if not ok then
        status = 0
    end
end

和状态将成功更新，如果lua_error失败。

但通常我认为这是一个糟糕的做法。如果更多光纤共享相同的状态，则由于光纤执行顺序的不确定性，可能难以维持。因此，为了获得更可靠的解决方案，您可能需要使用光纤间通信原语，即信道。您将能够使用channel:put（）和channel:get（）函数明确要求子光纤告诉您其执行状态是否成功。有关示例，请参阅文档。