nul*_*lll 7 php concurrency flock
我试图理解非阻塞flock和willblock参数
$fp = fopen('/tmp/lock.txt', 'r+');
if(flock($fp, LOCK_EX | LOCK_NB, $wouldblock)) {
echo 'Lock obtained';
}
else{
echo 'Unable to obtain lock';
}
fclose($fp);
Run Code Online (Sandbox Code Playgroud)
文档说关于wouldblock:
如果锁将阻塞(EWOULDBLOCK错误条件),则可选的第三个参数设置为1.
在测试环境中重现并发条件,如果另一个进程已获得锁定,则flock函数将立即返回FALSE(非阻塞)
那么,如果非阻塞模式下的flock函数的返回值已经告诉我无法获得锁定,为什么我要关心$ willblock值?
我无法区分flock函数返回FALSE和$ wouldblock参数设置为1,以及$ wouldblock参数有用的区别.
这是因为flock()可能失败不仅因为锁已经在其他地方获得了.在这种情况下,它不会阻止等待锁被释放,但它会立即返回false.换句话说,LOCK_NB如果flock返回false并且willblock = 1则意味着,它试图获得锁定,但它已经在其他地方获得了.但是如果flock LOCK_NB返回false并且willblock = 0那么这意味着发生了一些非常糟糕的事情,并且flock甚至没有考虑等待获得锁定,因为这是完全不可能的.
看看这段代码(这里也是一个要点):
<?php
// Let's create /tmp/ninja-lock1.txt ...
$fp0 = fopen('/tmp/ninja-lock1.txt', 'c');
// ... and close it imiedietly
fclose($fp0);
// File handler $fp0 was closed so flock()
// is unable to use it to gain lock.
// It will fail with wouldblock set to 0
// as it doesn't make sense to wait on unusable file handle.
//
// BTW flock() throws in such case warning "x is not a valid stream resource".
// Just for the purpose of clear output from this example
// I've suppressed it with @ - don't use @ in production
$flockResult = @flock($fp0, LOCK_EX | LOCK_NB, $wouldblock);
printf("flock=%b; wouldblock=%d (Acquire lock: %s)\n", $flockResult, $wouldblock, "failure, broken file handle");
// Two handlers for /tmp/ninja-lock2.txt
// to show flock() blocking result.
$fp1 = fopen('/tmp/ninja-lock2.txt', 'c');
$fp2 = fopen('/tmp/ninja-lock2.txt', 'c');
// Nobody is locking on /tmp/ninja-lock2.txt,
// so it will acquire lock and wouldblock will be 0
$flockResult = flock($fp1, LOCK_EX | LOCK_NB, $wouldblock);
printf("flock=%b; wouldblock=%d (Acquire lock: %s)\n", $flockResult, $wouldblock, "success");
// File is locked on $fp1 handle so flock won't acquire lock
// and wouldblock will be 1
$flockResult = flock($fp2, LOCK_EX | LOCK_NB, $wouldblock);
printf("flock=%b; wouldblock=%d (Acquire lock: %s)\n", $flockResult, $wouldblock, "failure, already acquired somewhere else");
// Result:
// $ php flock.php
// flock=0; wouldblock=0 (Acquire lock: failure, broken file handle)
// flock=1; wouldblock=0 (Acquire lock: success)
// flock=0; wouldblock=1 (Acquire lock: failure, already acquired somewhere else)
?>
Run Code Online (Sandbox Code Playgroud)
另外,为了清除未来读者的任何困惑,值得注意的是,检查EWOULDBLOCK只对带有LOCK_NB标志的flock()有意义,因为在阻塞模式下,它既可以成功,也可以是阻塞或失败,也不会阻塞.
您可以通过查看flock的php源代码来确认这一点:
PHPAPI int php_flock(int fd, int operation)
#if HAVE_STRUCT_FLOCK /* {{{ */
{
struct flock flck;
int ret;
flck.l_start = flck.l_len = 0;
flck.l_whence = SEEK_SET;
if (operation & LOCK_SH)
flck.l_type = F_RDLCK;
else if (operation & LOCK_EX)
flck.l_type = F_WRLCK;
else if (operation & LOCK_UN)
flck.l_type = F_UNLCK;
else {
errno = EINVAL;
return -1;
}
ret = fcntl(fd, operation & LOCK_NB ? F_SETLK : F_SETLKW, &flck);
if (operation & LOCK_NB && ret == -1 &&
(errno == EACCES || errno == EAGAIN))
errno = EWOULDBLOCK;
if (ret != -1) ret = 0;
return ret;
}
Run Code Online (Sandbox Code Playgroud)
EWOULDBLOCK仅在设置时才设置operation & LOCK_NB && ret == -1 &&
(errno == EACCES || errno == EAGAIN).
如果您对实现更感兴趣,还可以阅读fcntl的手册页,主要是关于F_SETLK和的部分F_SETLKW:
F_SETLK
获取锁(当l_type为F_RDLCK或F_WRLCK时)或释放锁(当l_type为F_UNLCK时)对l_whence,l_start和l_len锁定字段指定的字节.如果另一个进程持有冲突的锁,则此调用返回-1并将errno设置为EACCES或EAGAIN.
F_SETLKW
至于F_SETLK,但是如果文件上存在冲突的锁,则等待释放该锁.如果在等待时捕获到信号,则调用被中断并且(在信号处理程序返回之后)立即返回(返回值为-1且errno设置为EINTR).
| 归档时间: |
|
| 查看次数: |
1531 次 |
| 最近记录: |