mirror of
https://gitee.com/fastadminnet/framework.git
synced 2026-07-07 15:12:48 +08:00
缓存类的remember方法增加锁定机制
This commit is contained in:
19
library/think/cache/Driver.php
vendored
19
library/think/cache/Driver.php
vendored
@@ -120,10 +120,23 @@ abstract class Driver
|
|||||||
public function remember($name, $value, $expire = null)
|
public function remember($name, $value, $expire = null)
|
||||||
{
|
{
|
||||||
if (!$this->has($name)) {
|
if (!$this->has($name)) {
|
||||||
if ($value instanceof \Closure) {
|
while ($this->has($name . '.lock')) {
|
||||||
$value = call_user_func($value);
|
// 存在锁定则等待
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
// 锁定
|
||||||
|
$this->set($name . '.lock', true);
|
||||||
|
if ($value instanceof \Closure) {
|
||||||
|
$value = call_user_func($value);
|
||||||
|
}
|
||||||
|
$this->set($name, $value, $expire);
|
||||||
|
// 解锁
|
||||||
|
$this->rm($name . '.lock');
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
// 解锁
|
||||||
|
$this->rm($name . '.lock');
|
||||||
}
|
}
|
||||||
$this->set($name, $value, $expire);
|
|
||||||
} else {
|
} else {
|
||||||
$value = $this->get($name);
|
$value = $this->get($name);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user