openresty中lua vm中coroutine调度机制

coderesty · 2015-08-18T00:39:46+00:00

Hello! 2015-08-18 0:14 GMT+08:00 Jimmy Kuo: > 一直有个问题想咨询您。我们&#x...

openresty中lua vm中coroutine调度机制

coderesty

openresty中每个request创建一个coroutine, coroutine如果没有做I/O操作和sleep是不是会一直占用lua vm，直到这个请求结束？

openresty的coroutine调度机制是不是遇到I/O和sleep就让出CPU，其他情况不会让出CPU？

local _M = {}

local ffi = require("ffi")

ffi.cdef[[

	typedef long time_t;

 	typedef struct timeval {

		time_t tv_sec;

		time_t tv_usec;

	} timeval;

	int gettimeofday(struct timeval* t, void* tzp);

]]

local _M.gettimeofday_struct = ffi.new("timeval")

local function gettimeofday()

 	ffi.C.gettimeofday(_M.gettimeofday_struct, nil)

 	return tonumber(_M.gettimeofday_struct.tv_sec) * 1000000 + tonumber(_M.gettimeofday_struct.tv_usec)

end

我这个模块有一个模块变量gettimeofday_struct, 在openresty中多个request(coroutine) 会访问这个变量，请问会不会有race condition的问题？

doujiang24

在 2015年8月18日上午12:39，人cc <code...@gmail.com>写道：

openresty中每个request创建一个coroutine, coroutine如果没有做I/O操作和sleep是不是会一直占用lua vm，直到这个请求结束？

是的，所以必须非常谨慎处理一些热逻辑，比如这样就会整个 worker 被占用

while true do

-- forget to break

end

openresty的coroutine调度机制是不是遇到I/O和sleep就让出CPU，其他情况不会让出CPU？

并不是每种 I/O 都会，磁盘 I/O 就是阻塞的，ngx_lua 内部的 cosocket 就不会阻塞

也并不能严格的说遇到 I/O 就会让出 CPU，比如数据都已经在内核缓存区准备好了，此时 cosocket:read 也不会让出 CPU

local _M = {}
local ffi = require("ffi")
ffi.cdef[[
typedef long time_t;

typedef struct timeval {
time_t tv_sec;
time_t tv_usec;
} timeval;

int gettimeofday(struct timeval* t, void* tzp);
]]

local _M.gettimeofday_struct = ffi.new("timeval")
local function gettimeofday()
ffi.C.gettimeofday(_M.gettimeofday_struct, nil)
return tonumber(_M.gettimeofday_struct.tv_sec) * 1000000 + tonumber(_M.gettimeofday_struct.tv_usec)
end

我这个模块有一个模块变量gettimeofday_struct, 在openresty中多个request(coroutine) 会访问这个变量，请问会不会有race condition的问题？

不会的，这也是 lua 非抢占式协程的好处

--