lua-resty-thread

easy use to ngx.run_worker_thread, none block

Description

wrapper ngx.run_worker_thread api, and support normally io api, like file.

diffrence result

convert result if runtime error return, it's like this:

      local ok, r1, ... = thread.run(...)
      if not ok then
          return nil, r1
      end
      return r1, ...

Public Functions

run()

pass callback function to ngx.run_worker_thread without create a new file.

note: function must without up values.

run_worker_thread()

it's same as ngx.run_worker_thread.

run_with_upvalues()

pass callback function to ngx.run_worker_thread without create a new file.

note: upvalues list must doesn't include

• thread

• userdata

• c function

set_upvalues_maxlimit

function run_with_upvalues serialize upvalues level limit.

new

banding argument threadpool_name, all functions is same as resty.thread except no first argument.

note:

• if flag support_thread is false, return a wrapper object which all api will call functions in current thread.

• if thread pool is invalid, will return nil, error message

| Filed | Name | Lua Type | Description | | ------------ | ----------------- | --------- | ---------------------------------------------------------------------- | | Parameter | threadpool_name | string | thread pool name | | Parameter | no_check | boolean | set true will return wrapper object when thread pool is not invaild. | | Return Value | handle | table/nil | instance reference |

support_thread

flag whether this function is supported.