swoole协程怎么按代码的执行顺序输出
使用协程写代码本来就是同步的写法。。。
channel
在一个协程中本来就是同步执行的,当正在执行的协程遇到阻塞IO等,那么当前的协程就会挂起来,让出cpu的控制权,那么底层协程调度器就会激活恢复另一个挂起的协程,然后继续从原来挂起的逻辑地方继续往下执行,所以在一个协程中逻辑都是同步执行的。
手动用 Swoole\Coroutine::create(function(){}) 开启的多个协程,它们之间的通信需要使用 Swoole\Coroutine\Channel.
Swoole\Coroutine::create(function(){})
Swoole\Coroutine\Channel
var_export(get_class_methods('Swoole\Coroutine\Channel')); 可见: array ( 0 => '__construct', // 通道默认容量为0,表示无缓冲区,push(生成)和pop(消费)操作会立即挂起当前协程. 1 => '__destruct', 2 => 'push', // 当队列中有其他协程正在等待pop(消费)数据时,push(生产)操作会自动按顺序唤醒一个消费者协程.当队列已满时自动yield(让出)控制器,等待其他协程pop(消费)数据. 3 => 'pop', // 当队列为空时自动yield,等待其他协程push(生产)数据.pop(消费)数据后,队列可写入新的数据,自动按顺序唤醒一个生产者协程. 4 => 'isEmpty', // 检测通道是否为空 5 => 'isFull', // 检测通道是否已满 6 => 'close', // 关闭通道,并唤醒所有等待读写的协程. 7 => 'stats', // 包含信息queue_num(通道中的元素数量)和queue_bytes(通道当前占用的内存字节数). 8 => 'length', // 通道中的队列长度,等价于 $chan->stats()['queue_num'] 9 => 'select', // 通道读写检测,类似于socket_select和stream_select. )
对于一些协程客户端,可以直接使用顺序的写法:
$redis = new Swoole\Coroutine\Redis(); $redis->connect(REDIS_SERVER_HOST, REDIS_SERVER_PORT); // 发生协程切换 $redis->set('key1', 'value'); // 发生协程切换
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
暂无简介
文章 0 评论 0
接受
发布评论
评论(4)
使用协程写代码本来就是同步的写法。。。
channel
在一个协程中本来就是同步执行的,当正在执行的协程遇到阻塞IO等,那么当前的协程就会挂起来,让出cpu的控制权,那么底层协程调度器就会激活恢复另一个挂起的协程,然后继续从原来挂起的逻辑地方继续往下执行,所以在一个协程中逻辑都是同步执行的。
手动用
Swoole\Coroutine::create(function(){})
开启的多个协程,它们之间的通信需要使用
Swoole\Coroutine\Channel
.对于一些协程客户端,可以直接使用顺序的写法: