在nginx中,ngx_time_update函数可以被多个线程执行,但只要有一个线程执行了这个函数,其他线程无需执行这个函数。
对于这种需求,nginx给出的实现方案挺有意思。
ngx_time_update开头两句如下:
if (!ngx_trylock(&ngx_time_lock)) {
return;
}
// do something...
ngx_unlock(&ngx_time_lock);
ngx_trylock和ngx_unlock都是宏定义,代码如下:
BJXShop网上购物系统是一个高效、稳定、安全的电子商店销售平台,经过近三年市场的考验,在中国网购系统中属领先水平;完善的订单管理、销售统计系统;网站模版可DIY、亦可导入导出;会员、商品种类和价格均实现无限等级;管理员权限可细分;整合了多种在线支付接口;强有力搜索引擎支持... 程序更新:此版本是伴江行官方商业版程序,已经终止销售,现于免费给大家使用。比其以前的免费版功能增加了:1,整合了论坛
#define ngx_trylock(lock) (*(lock) == 0 && ngx_atomic_cmp_set(lock, 0, 1)) #define ngx_unlock(lock) *(lock) = 0
继续展开ngx_atomic_cmp_set
#define ngx_atomic_cmp_set(lock, old, set) \
((ngx_atomic_uint_t) InterlockedCompareExchange((long *) lock, set, old) \
== old)ngx_atomic_uint_t是unsigned int的类型别名。
至此,可以看出这种同步方案是使用InterlockedCompareExchange实现的。
首先,Interlocked系列函数能够保证操作的原子性。
假设现在ngx_time_lock变量的值为0,有两个线程都要执行InterlockedCompareExchange这个函数了。此时,只会有一个线程先执行,它改变了ngx_time_lock的值为1,并返回0。另外一个线程用新的ngx_time_lock值(也就是1)跟0进行比较,此时,不会发生交换,并且返回原始的值1,保证这个线程在if判断处返回。
另外,ngx_atomic_t的类型定义为:typedef volatile unsigned int ngx_atomic_t;
以上就介绍了nginx中的多线程时间更新模型,包括了方面的内容,希望对PHP教程有兴趣的朋友有所帮助。









