php运用swoole协程(go) 管道(channel)机制

常量定义

defined('CHANNEL_SIZE') or define('CHANNEL_SIZE', 2345); //创建管道容量

示例代码

class Test {

	public function market()
	{
		$channel = new Channel(CHANNEL_SIZE);
	
		go(function() use ($channel){ //此为swoole的go协程，实际是个闭包运用
		   $data = $this->getMarket(); //数据集
		   $channel->push($data);//将数据集插入进管道
		});
		
		$popData = $channel->pop();
		var_dump($popData);
	}
	
	public function getMarket()
	{
		return 1;
	}
}

到此这篇关于“php运用swoole协程(go) 管道(channel)机制”的文章就介绍到这了,更多文章或继续浏览下面的相关文章，希望大家以后多多支持JQ教程网！

您可能感兴趣的文章：
php运用swoole协程(go) 管道(channel)机制
php有哪些运行环境
go语言并发编程
go channel 使用及机制流程汇总
Swoole协程与传统fpm同步模式比较
2020-10-19Go语言goroutine和channel
Go 语言为什么这么快，带你详细了解Golang CSP并发模型
2020最新swoole视频教程推荐（从入门到高级）
golang学习笔记（二）—— 深入golang中的协程
golang channel的使用以及调度原理