
Mutex组件允许并发进程的相互执行,以防止“竞争条件”。这是通过使用“锁定”机制实现的。每个可能并发的线程通过在访问相应数据之前获取锁来进行协作。
相关推荐:yii教程
用法示例:
if ($mutex->acquire($mutexName)) { // business logic execution} else { // execution is blocked!}
这是一个基类,应该扩展它以实现实际的锁机制。
AppMall应用商店
AI应用商店,提供即时交付、按需付费的人工智能应用服务
56 查看详情
下面我们看看其源码实现:
acquire($mutexName)) { * // business logic execution * } else { * // execution is blocked! * } * ``` * * This is a base class, which should be extended in order to implement the actual lock mechanism. * * @author resurtm * @since 2.0 */abstract class Mutex extends Component{ /** * @var bool whether all locks acquired in this process (i.e. local locks) must be released automatically * before finishing script execution. Defaults to true. Setting this property to true means that all locks * acquired in this process must be released (regardless of errors or exceptions). */ public $autoRelease = true;//是否自动释放锁 /** * @var string[] names of the locks acquired by the current PHP process. */ private $_locks = [];//当前进程拥有的锁信息 /** * 初始化Mutex组件 */ public function init() { if ($this->autoRelease) {//如果是自动释放锁 $locks = &$this->_locks; //注册shutdown回调函数,在这里做锁的释放动作 register_shutdown_function(function () use (&$locks) { foreach ($locks as $lock) { $this->release($lock); } }); } } /** * Acquires a lock by name. * @param string $name of the lock to be acquired. Must be unique. * @param int $timeout time (in seconds) to wait for lock to be released. Defaults to zero meaning that method will return * false immediately in case lock was already acquired. * @return bool lock acquiring result. */ public function acquire($name, $timeout = 0)//按名称获取锁 { if ($this->acquireLock($name, $timeout)) { $this->_locks[] = $name; return true; } return false; } /** * Releases acquired lock. This method will return false in case the lock was not found. * @param string $name of the lock to be released. This lock must already exist. * @return bool lock release result: false in case named lock was not found.. */ public function release($name)//按名称释放锁 { if ($this->releaseLock($name)) { $index = array_search($name, $this->_locks); if ($index !== false) { unset($this->_locks[$index]); } return true; } return false; } /** * This method should be extended by a concrete Mutex implementations. Acquires lock by name. * @param string $name of the lock to be acquired. * @param int $timeout time (in seconds) to wait for the lock to be released. * @return bool acquiring result. */ abstract protected function acquireLock($name, $timeout = 0);//抽象函数,按名称获取锁 /** * This method should be extended by a concrete Mutex implementations. Releases lock by given name. * @param string $name of the lock to be released. * @return bool release result. */ abstract protected function releaseLock($name);//抽象函数,按名称释放锁}
其作为基础类,子类需要实现acquireLock和releaseLock方法,即具体的加锁和解锁策略。
以上就是mutex yii怎么用的详细内容,更多请关注创想鸟其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/360427.html
微信扫一扫
支付宝扫一扫