Generator implements Iterator {
public mixed current ( void ) // 返回当前产生的值
public mixed key ( void ) // 返回当前产生的键
public void next ( void ) // 生成器继续执行
public void rewind ( void ) // 重置迭代器,如果迭代已经开始了,这里会抛出一个异常。
// renwind的执行将会导致第一个yield被执行, 并且忽略了他的返回值.
public mixed send ( mixed $value ) // 向生成器中传入一个值,并且当做 yield 表达式的结果,然后继续执行生成器。如果当这个方法被调用时,生成器
// 不在 yield 表达式,那么在传入值之前,它会先运行到第一个 yield 表达式。
public void throw ( Exception $exception ) // 向生成器中抛入一个异常
public bool valid ( void ) // 检查迭代器是否被关闭
public void __wakeup ( void ) // 序列化回调,抛出一个异常以表示生成器不能被序列化。
}
class timer {
private $start = 0; // 定时开始时间
private $timer; // 间隔的时间差,单位秒
private $value = 0; // 产生的结果值
private $callback; // 异步回调
private $isEnd = false; // 当前定时器任务是否结束
public function __construct($timer,callable $callback)
{
$this->start = time();
$this->timer = $timer;
$this->callback = $callback;
}
public function run() {
if($this->valid()) {
$callback = $this->callback;
$callback($this->value ++,$this);
$this->start = time();
}
}
/**
* 定时执行检查
*/
public function valid() {
$end = time();
if($end - $this->start >= $this->timer) {
return true;
} else {
return false;
}
}
public function setEnd($isEnd) {
$this->isEnd = $isEnd;
}
public function getEnd() {
return $this->isEnd;
}
}
/**
* 模拟阻塞的协程1
*
*/
function taskObject1() {
$timer = new timer(1,function($value,timer $timer) {
if($value >= 5) {
$timer->setEnd(true);
}
echo '<br>'.'A '.$value;
});
$tid = (yield getTaskId());
while (true) {
if($timer->getEnd() == true) {
break;
}
yield $timer->run();
}
}
/**
* 模拟阻塞的协程2
*
*/
function taskObject2() {
$timer = new timer(2,function($value,timer $timer) {
if($value >= 3) {
$timer->setEnd(true);
}
echo '<br>'.'B '.$value;
});
$tid = (yield getTaskId());
while (true) {
if($timer->getEnd() == true) {
break;
}
yield $timer->run();
}
}
$scheduler = new Scheduler;
$scheduler->newTask(taskObject1());
$scheduler->newTask(taskObject2());
$scheduler->run();
// 一个简单的例子
<?php
function xrange($start, $end, $step = 1) {
for ($i = $start; $i <= $end; $i += $step) {
yield $i;
}
}
foreach (xrange(1, 1000000) as $num) {
echo $num, "\n";
}
机械节能产品生产企业官网模板...
大气智能家居家具装修装饰类企业通用网站模板...
礼品公司网站模板
宽屏简约大气婚纱摄影影楼模板...
蓝白WAP手机综合医院类整站源码(独立后台)...苏ICP备2024110244号-2 苏公网安备32050702011978号 增值电信业务经营许可证编号:苏B2-20251499 | Copyright 2018 - 2025 源码网商城 (www.ymwmall.com) 版权所有