tofu-extend-lockstep

lockstep extend of tofu

很多业务都是有序的，或必须当某个业务完成后才能执行下一个业务。这时我们就需要在多个worker工作模式下，进行同步执行某个业务，确保业务的有序性。

安装

    -- 在项目配置文件 tofu.package.lua 添加
    
    deps = {
    
      --
      -- 其它配置 ...
      --
    
      'd80x86/tofu-extend.lockstep',
    }
    

使用tofu安装

    ./tofu install

使用配置

    -- 项目配置文件 conf/extend.lua
    
    extend = {
    
      -- 添加同步执行扩展组件
      {
        named = 'lockstep',
        default = {
          handle = 'resty.tofu.extend.lockstep',
          options = {}
        }
      }
    
    }
    

配置options

| 参数名 | 类型 | 说明 | 缺省 | | ------- | ------ | ------------------- | ------------------ | | timeout | float | 锁定超时时长(秒) | 5 | | shm | string | ngx.share.DICT 名称 | tofu_lockstep_dict |

Lua API

tofu.lockstep(key, fun [, ...args])

以key为原子锁，直到 fun 函数执行完后自动释放锁。return fun(...args)

• key string 键名称

• fun function 函数

• ...args any fun 函数的参数

使用样例

    local key = 'printer'
    local fun = function (user_id)
                                -- ... 业务处理
                         end
    tofu.lockstep(key, fun, user_id)