如何在后台开启轻量级线程来定时更新共享内存？

382482175 · 2016-08-08T12:12:22+00:00

Hello! 2016-08-04 4:46 GMT-07:00 YHUJY7ITI76I : > "" 为nginx中的保留字段，但是&#x59...

如何在后台开启轻量级线程来定时更新共享内存？

382482175

现在有一个场景：需要定时（30s）从redis里面拉取数据灌入lua cache共享内存。

我现在是用ngx.timer 这个API来实现的，请问这会不会有问题？因为对ngx.timer这个API不是很了解

看了文档说是：在后台开启了一个轻量级线程来执行，与原来的请求脱钩。

我这边的场景就是拉取灌入的操作不能阻塞worker。

1，请问这样能够满足需求吗？会不会有阻塞问题？

2，ngx.timer我现在是放在content_by_lua_file中的，需要访问接口才能启动，有没有可以开启worker的时候就启动timer的办法（我试了放在init_by_lua_file里面好像不生效。。。）

3 ，这个timer是每个worker里面都会有还是只有一个worker里面会有呢？（看文档貌似是只有一个worker里面会有，这也是我的需求）

谢谢：）

toruneko.dai

应该要用init_worker_by_lua，在worker进程启动的时候调用ngx.timer

如果只想要一个worker有timer，可以在worker启动的时候去竞争一把锁，抢到锁的worker创建timer。

在 2016年8月8日星期一 UTC+8下午12:12:23，wwaz wwaz写道：

现在有一个场景：需要定时（30s）从redis里面拉取数据灌入lua cache共享内存。
我现在是用ngx.timer 这个API来实现的，请问这会不会有问题？因为对ngx.timer这个API不是很了解
看了文档说是：在后台开启了一个轻量级线程来执行，与原来的请求脱钩。
我这边的场景就是拉取灌入的操作不能阻塞worker。

1，请问这样能够满足需求吗？会不会有阻塞问题？
2，ngx.timer我现在是放在content_by_lua_file中的，需要访问接口才能启动，有没有可以开启worker的时候就启动timer的办法（我试了放在init_by_lua_file里面好像不生效。。。）
3 ，这个timer是每个worker里面都会有还是只有一个worker里面会有呢？（看文档貌似是只有一个worker里面会有，这也是我的需求）

谢谢：）

toruneko.dai

参考这个：

https://groups.google.com/forum/#!topic/openresty/rIh0eO2Isz8

在 2016年8月8日星期一 UTC+8下午1:07:08，Jianhao Dai写道：

应该要用init_worker_by_lua，在worker进程启动的时候调用ngx.timer
如果只想要一个worker有timer，可以在worker启动的时候去竞争一把锁，抢到锁的worker创建timer。

在 2016年8月8日星期一 UTC+8下午12:12:23，wwaz wwaz写道：
现在有一个场景：需要定时（30s）从redis里面拉取数据灌入lua cache共享内存。
我现在是用ngx.timer 这个API来实现的，请问这会不会有问题？因为对ngx.timer这个API不是很了解
看了文档说是：在后台开启了一个轻量级线程来执行，与原来的请求脱钩。
我这边的场景就是拉取灌入的操作不能阻塞worker。

1，请问这样能够满足需求吗？会不会有阻塞问题？
2，ngx.timer我现在是放在content_by_lua_file中的，需要访问接口才能启动，有没有可以开启worker的时候就启动timer的办法（我试了放在init_by_lua_file里面好像不生效。。。）
3 ，这个timer是每个worker里面都会有还是只有一个worker里面会有呢？（看文档貌似是只有一个worker里面会有，这也是我的需求）

谢谢：）

soaercom

用work.id()函数来判断，就不需要加锁了

382482175

嗯，这个很符合场景。谢谢：）

在 2016年8月7日星期日 UTC-7下午10:08:49，Jianhao Dai写道：

参考这个：
https://groups.google.com/forum/#!topic/openresty/rIh0eO2Isz8

在 2016年8月8日星期一 UTC+8下午1:07:08，Jianhao Dai写道：
应该要用init_worker_by_lua，在worker进程启动的时候调用ngx.timer
如果只想要一个worker有timer，可以在worker启动的时候去竞争一把锁，抢到锁的worker创建timer。

在 2016年8月8日星期一 UTC+8下午12:12:23，wwaz wwaz写道：
现在有一个场景：需要定时（30s）从redis里面拉取数据灌入lua cache共享内存。
我现在是用ngx.timer 这个API来实现的，请问这会不会有问题？因为对ngx.timer这个API不是很了解
看了文档说是：在后台开启了一个轻量级线程来执行，与原来的请求脱钩。
我这边的场景就是拉取灌入的操作不能阻塞worker。

1，请问这样能够满足需求吗？会不会有阻塞问题？
2，ngx.timer我现在是放在content_by_lua_file中的，需要访问接口才能启动，有没有可以开启worker的时候就启动timer的办法（我试了放在init_by_lua_file里面好像不生效。。。）
3 ，这个timer是每个worker里面都会有还是只有一个worker里面会有呢？（看文档貌似是只有一个worker里面会有，这也是我的需求）

谢谢：）

382482175

哥们，你的这个问题解决了吗？是不是在init_work_by_lua 中设定的定时器。我和你的场景很类似，都是需要定时更新shard dict，只需要一个worker来做。

在 2016年8月7日星期日 UTC-7下午10:37:46，soae...@gmail.com写道：

用work.id()函数来判断，就不需要加锁了

382482175

另外我看ngx.timer的文档，后台起了一个轻量级线程来做跑的timer里面的函数的。不知道这个轻量级线程和原来的worker是个啥关系呢？

在 2016年8月7日星期日 UTC-7下午11:16:01，wwaz wwaz写道：

嗯，这个很符合场景。谢谢：）

在 2016年8月7日星期日 UTC-7下午10:08:49，Jianhao Dai写道：
参考这个：
https://groups.google.com/forum/#!topic/openresty/rIh0eO2Isz8

在 2016年8月8日星期一 UTC+8下午1:07:08，Jianhao Dai写道：
应该要用init_worker_by_lua，在worker进程启动的时候调用ngx.timer
如果只想要一个worker有timer，可以在worker启动的时候去竞争一把锁，抢到锁的worker创建timer。

在 2016年8月8日星期一 UTC+8下午12:12:23，wwaz wwaz写道：
现在有一个场景：需要定时（30s）从redis里面拉取数据灌入lua cache共享内存。
我现在是用ngx.timer 这个API来实现的，请问这会不会有问题？因为对ngx.timer这个API不是很了解
看了文档说是：在后台开启了一个轻量级线程来执行，与原来的请求脱钩。
我这边的场景就是拉取灌入的操作不能阻塞worker。

1，请问这样能够满足需求吗？会不会有阻塞问题？
2，ngx.timer我现在是放在content_by_lua_file中的，需要访问接口才能启动，有没有可以开启worker的时候就启动timer的办法（我试了放在init_by_lua_file里面好像不生效。。。）
3 ，这个timer是每个worker里面都会有还是只有一个worker里面会有呢？（看文档貌似是只有一个worker里面会有，这也是我的需求）

谢谢：）

382482175

请问抢锁如何实现呀，有没有相应的API？？：）

在 2016年8月7日星期日 UTC-7下午10:07:08，Jianhao Dai写道：

应该要用init_worker_by_lua，在worker进程启动的时候调用ngx.timer
如果只想要一个worker有timer，可以在worker启动的时候去竞争一把锁，抢到锁的worker创建timer。

在 2016年8月8日星期一 UTC+8下午12:12:23，wwaz wwaz写道：
现在有一个场景：需要定时（30s）从redis里面拉取数据灌入lua cache共享内存。
我现在是用ngx.timer 这个API来实现的，请问这会不会有问题？因为对ngx.timer这个API不是很了解
看了文档说是：在后台开启了一个轻量级线程来执行，与原来的请求脱钩。
我这边的场景就是拉取灌入的操作不能阻塞worker。

1，请问这样能够满足需求吗？会不会有阻塞问题？
2，ngx.timer我现在是放在content_by_lua_file中的，需要访问接口才能启动，有没有可以开启worker的时候就启动timer的办法（我试了放在init_by_lua_file里面好像不生效。。。）
3 ，这个timer是每个worker里面都会有还是只有一个worker里面会有呢？（看文档貌似是只有一个worker里面会有，这也是我的需求）

谢谢：）

yuansheng

2016-08-08 16:05 GMT+08:00 wwaz wwaz <3824...@qq.com>:

请问抢锁如何实现呀，有没有相应的API？？：）

如果你只需要一个实例工作，用work.id()函数来判断就好

在 2016年8月7日星期日 UTC-7下午10:07:08，Jianhao Dai写道：
应该要用init_worker_by_lua，在worker进程启动的时候调用ngx.timer
如果只想要一个worker有timer，可以在worker启动的时候去竞争一把锁，抢到锁的worker创建timer。

在 2016年8月8日星期一 UTC+8下午12:12:23，wwaz wwaz写道：
现在有一个场景：需要定时（30s）从redis里面拉取数据灌入lua cache共享内存。
我现在是用ngx.timer 这个API来实现的，请问这会不会有问题？因为对ngx.timer这个API不是很了解
看了文档说是：在后台开启了一个轻量级线程来执行，与原来的请求脱钩。
我这边的场景就是拉取灌入的操作不能阻塞worker。

1，请问这样能够满足需求吗？会不会有阻塞问题？
2，ngx.timer我现在是放在content_by_lua_file中的，需要访问接口才能启动，有没有可以开启worker的时候就启动timer的办法（我试了放在init_by_lua_file里面好像不生效。。。）
3 ，这个timer是每个worker里面都会有还是只有一个worker里面会有呢？（看文档貌似是只有一个worker里面会有，这也是我的需求）

谢谢：）

--

YuanSheng Wang

---------------------------------------

My Github: https://github.com/membphis

OpenResty lover ^_^

382482175

我在tengine里面做的，现在ngx.worker.id不支持tengine。

估计要用刀lua-resty-lock. 锁

在 2016年8月8日星期一 UTC-7上午1:32:31，YuanSheng写道：

2016-08-08 16:05 GMT+08:00 wwaz wwaz <3824...@qq.com>:
请问抢锁如何实现呀，有没有相应的API？？：）

如果你只需要一个实例工作，用work.id()函数来判断就好

在 2016年8月7日星期日 UTC-7下午10:07:08，Jianhao Dai写道：
应该要用init_worker_by_lua，在worker进程启动的时候调用ngx.timer
如果只想要一个worker有timer，可以在worker启动的时候去竞争一把锁，抢到锁的worker创建timer。

在 2016年8月8日星期一 UTC+8下午12:12:23，wwaz wwaz写道：
现在有一个场景：需要定时（30s）从redis里面拉取数据灌入lua cache共享内存。
我现在是用ngx.timer 这个API来实现的，请问这会不会有问题？因为对ngx.timer这个API不是很了解
看了文档说是：在后台开启了一个轻量级线程来执行，与原来的请求脱钩。
我这边的场景就是拉取灌入的操作不能阻塞worker。

1，请问这样能够满足需求吗？会不会有阻塞问题？
2，ngx.timer我现在是放在content_by_lua_file中的，需要访问接口才能启动，有没有可以开启worker的时候就启动timer的办法（我试了放在init_by_lua_file里面好像不生效。。。）
3 ，这个timer是每个worker里面都会有还是只有一个worker里面会有呢？（看文档貌似是只有一个worker里面会有，这也是我的需求）

谢谢：）

--

--

YuanSheng Wang
---------------------------------------
My Github: https://github.com/membphis
OpenResty lover ^_^

toruneko.dai

恩，用lua-resty-lock，竞争到了就可以创建timer了。

调用了ngx.timer.at，就会把这个定时任务扔到event里，时间到了就起一个轻线程跑callback。

要说什么关系，就是轻线程还是在worker里跑吧。

这里的轻线程应该是类似协程的东西，只要不做什么blocking的事情，同步非阻塞IO可以带你飞的。。

在 2016年8月8日星期一 UTC+8下午5:50:51，wwaz wwaz写道：

我在tengine里面做的，现在ngx.worker.id不支持tengine。
估计要用刀lua-resty-lock. 锁

在 2016年8月8日星期一 UTC-7上午1:32:31，YuanSheng写道：

2016-08-08 16:05 GMT+08:00 wwaz wwaz <3824...@qq.com>:
请问抢锁如何实现呀，有没有相应的API？？：）

如果你只需要一个实例工作，用work.id()函数来判断就好

在 2016年8月7日星期日 UTC-7下午10:07:08，Jianhao Dai写道：
应该要用init_worker_by_lua，在worker进程启动的时候调用ngx.timer
如果只想要一个worker有timer，可以在worker启动的时候去竞争一把锁，抢到锁的worker创建timer。

在 2016年8月8日星期一 UTC+8下午12:12:23，wwaz wwaz写道：
现在有一个场景：需要定时（30s）从redis里面拉取数据灌入lua cache共享内存。
我现在是用ngx.timer 这个API来实现的，请问这会不会有问题？因为对ngx.timer这个API不是很了解
看了文档说是：在后台开启了一个轻量级线程来执行，与原来的请求脱钩。
我这边的场景就是拉取灌入的操作不能阻塞worker。

1，请问这样能够满足需求吗？会不会有阻塞问题？
2，ngx.timer我现在是放在content_by_lua_file中的，需要访问接口才能启动，有没有可以开启worker的时候就启动timer的办法（我试了放在init_by_lua_file里面好像不生效。。。）
3 ，这个timer是每个worker里面都会有还是只有一个worker里面会有呢？（看文档貌似是只有一个worker里面会有，这也是我的需求）

谢谢：）

--

--

YuanSheng Wang
---------------------------------------
My Github: https://github.com/membphis
OpenResty lover ^_^

382482175

多谢指导，谢谢分享，已经解决了。

使用的worker id的方式，小小改动了下tengine的代码。

：）

在 2016年8月9日星期二 UTC-7下午7:24:45，Jianhao Dai写道：

恩，用lua-resty-lock，竞争到了就可以创建timer了。
调用了ngx.timer.at，就会把这个定时任务扔到event里，时间到了就起一个轻线程跑callback。
要说什么关系，就是轻线程还是在worker里跑吧。
这里的轻线程应该是类似协程的东西，只要不做什么blocking的事情，同步非阻塞IO可以带你飞的。。

在 2016年8月8日星期一 UTC+8下午5:50:51，wwaz wwaz写道：
我在tengine里面做的，现在ngx.worker.id不支持tengine。
估计要用刀lua-resty-lock. 锁

在 2016年8月8日星期一 UTC-7上午1:32:31，YuanSheng写道：

2016-08-08 16:05 GMT+08:00 wwaz wwaz <3824...@qq.com>:
请问抢锁如何实现呀，有没有相应的API？？：）

如果你只需要一个实例工作，用work.id()函数来判断就好

在 2016年8月7日星期日 UTC-7下午10:07:08，Jianhao Dai写道：
应该要用init_worker_by_lua，在worker进程启动的时候调用ngx.timer
如果只想要一个worker有timer，可以在worker启动的时候去竞争一把锁，抢到锁的worker创建timer。

在 2016年8月8日星期一 UTC+8下午12:12:23，wwaz wwaz写道：
现在有一个场景：需要定时（30s）从redis里面拉取数据灌入lua cache共享内存。
我现在是用ngx.timer 这个API来实现的，请问这会不会有问题？因为对ngx.timer这个API不是很了解
看了文档说是：在后台开启了一个轻量级线程来执行，与原来的请求脱钩。
我这边的场景就是拉取灌入的操作不能阻塞worker。

1，请问这样能够满足需求吗？会不会有阻塞问题？
2，ngx.timer我现在是放在content_by_lua_file中的，需要访问接口才能启动，有没有可以开启worker的时候就启动timer的办法（我试了放在init_by_lua_file里面好像不生效。。。）
3 ，这个timer是每个worker里面都会有还是只有一个worker里面会有呢？（看文档貌似是只有一个worker里面会有，这也是我的需求）

谢谢：）

--

--

YuanSheng Wang
---------------------------------------
My Github: https://github.com/membphis
OpenResty lover ^_^

agentzh

Hello!

2016-08-10 7:58 GMT-07:00 wwaz wwaz:
> 多谢指导，谢谢分享，已经解决了。
> 使用的worker id的方式，小小改动了下tengine的代码。
> ：）
>

不推荐使用 Tengine，里面的 ngx_lua 模块年久失修。我们是不对这种配置提供支持的。

Regards,
-agentzh