
Swoole 协程 sleep() 函数导致死锁的深入分析
本文探讨 Swoole 协程中 sleep() 函数可能导致死锁的问题,并通过代码示例详细分析原因及解决方案。
问题重现
在 Swoole 4.8.9 版本中,运行以下代码会引发“[fatal error]: all coroutines (count: 1) are asleep – deadlock!”错误:
<?php
use Swoole/Process;
class Deadlock
{
public function startProcess()
{
$t = new Swoole/Process(function () {
swoole_async_set(['enable_coroutine' => true]);
go(function (){
while (true) {
Swoole/Coroutine/System::sleep(1);
var_dump('dd');
}
});
});
$t->start();
}
}
$proc = new Process(function () {
swoole_async_set(['enable_coroutine' => false]);
$cls = new Deadlock();
Swoole/Timer::after(1000, function () use ($cls) {
$cls->startProcess(); // 延迟一秒后启动子进程
});
});
$proc->start();
登录后复制
根源剖析
代码中,Deadlock 类启动一个子进程,并在子进程中启用协程,该协程无限循环调用 Swoole/Coroutine/System::sleep(1)。关键在于父进程的配置和调用时机:
- 父进程禁用协程: swoole_async_set([‘enable_coroutine’ => false]) 在父进程中禁用了协程。
- 延迟调用: 父进程使用 Swoole/Timer::after(1000, …) 延迟一秒后,才调用 startProcess() 启动子进程中的协程。
由于父进程未启用协程,当子进程中的协程进入 sleep() 状态后,系统中没有其他可执行的协程,导致所有协程休眠,从而引发死锁。
解决方案
为了避免死锁,需要保持父进程和子进程的协程环境一致性。以下两种方法可以解决问题:
方法一:父进程启用协程
在父进程中启用协程,允许父进程在子进程协程休眠时继续执行其他任务:
<?php
// ... (Deadlock 类代码不变) ...
$proc = new Process(function () {
swoole_async_set(['enable_coroutine' => true]); // 启用父进程协程
$cls = new Deadlock();
Swoole/Timer::after(1000, function () use ($cls) {
$cls->startProcess();
});
});
$proc->start();
登录后复制
方法二:子进程禁用协程 (不推荐)
在子进程中禁用协程,虽然避免了死锁,但失去了协程带来的并发优势:
<?php
use Swoole/Process;
class Deadlock
{
public function startProcess()
{
$t = new Swoole/Process(function () {
// swoole_async_set(['enable_coroutine' => true]); // 禁用子进程协程
for (; ;) {
sleep(1); // 使用同步sleep
var_dump('dd');
}
});
$t->start();
}
}
// ... (父进程代码不变) ...
登录后复制
推荐使用方法一,即在父进程中启用协程,以充分利用 Swoole 协程的优势。 方法二虽然解决了死锁,但失去了协程的并发性,降低了程序效率。
通过以上分析和修改,我们可以有效避免 Swoole 协程 sleep() 函数导致的死锁问题,确保程序的稳定性和高效性。
以上就是Swoole 协程中 sleep 为什么会导致死锁?的详细内容,更多请关注php中文网其它相关文章!