关于PHP协程与阻塞的思考

FullStackDeveloper 发布于2019-06-28 13:22 / 3031人阅读

摘要：线程拥有自己独立的栈和共享的堆，共享堆，不共享栈，线程亦由操作系统调度标准线程是的。以及鸟哥翻译的这篇详细文档我就以他实现的协程多任务调度为基础做一下例子说明并说一下关于我在阻塞方面所做的一些思考。

进程、线程、协程

关于进程、线程、协程，有非常详细和丰富的博客或者学习资源，我不在此做赘述，我大致在此介绍一下这几个东西。

进程拥有自己独立的堆和栈，既不共享堆，亦不共享栈，进程由操作系统调度。

线程拥有自己独立的栈和共享的堆，共享堆，不共享栈，线程亦由操作系统调度(标准线程是的)。

协程和线程一样共享堆，不共享栈，协程由程序员在协程的代码里显示调度。

PHP中的协程实现基础 yield

yield的根本实现是生成器类，而迭代器类是迭代器接口的实现：

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 ) // 序列化回调，抛出一个异常以表示生成器不能被序列化。
}

以上解析可以参考PHP官方文档。

http://php.net/manual/zh/clas...

以及鸟哥翻译的这篇详细文档：

http://www.laruence.com/2015/...

我就以他实现的协程多任务调度为基础做一下例子说明并说一下关于我在阻塞方面所做的一些思考。

自定义简单定时执行任务示例：

(此例子必须依赖于以上鸟哥实现的协程调度代码)


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 "
"."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 "
"."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();

以上实现的是：

产生两个任务，并行执行，并且给每个任务在执行的时候模拟几秒钟的阻塞；

让协程切换的时候能顺利切换，其中的任务阻塞不相互影响；

思考：

我为什么要做以上这件事情呢？因为我发现协程实现虽然很强大也很有意思，能让多任务并行，但是我在其中一个任务里调用系统函数 sleep() 的时候,阻塞任务会阻止协程切换，其实从协程的实现原理上来说也是这么回事。

那么，我也就想模拟协程阻塞，但是不产生阻塞看是否可行。PHP本身只提供了生成器为协程调用提供了支撑，如果不依赖扩展，没有提供多线程的程序实现方式，没有java那么强大，可以开子线程进行实现。

我印象中java的子线程是独立执行且不会相互阻塞的，所以我在想，PHP既然可以实现类似于多线程这样的机制，那么能不能实现调用过程中非阻塞呢？

经过这样一个实现和思考，一开始是陷入了一个误区的，是由于PHP原生函数 sleep() 阻塞造成的思维误区，那就是认为要想真正实现非阻塞或者说实现异步的话，是必须依赖于语言底层的。

后来，我想明白了一个道理，既然某个方法或者函数在执行过程中，会产生阻塞，那么把当前这个方法换成自定义的，做成非阻塞（相对于整个协程调度来说）不就行了吗？比如上面的定时执行我自己实现了一个。

而另一方面，协程调度本身的目的也是为了把任务执行过程切成尽量小片，从而快速切换执行，达到并行的目的。从这方面来看，协程应该也算是一种程序设计思想。

以下是一个程序切成尽量小片执行的例子：

// 一个简单的例子

这个例子是把原本用 range 生成一个很大的整型数组的方式切换为分片执行，也就是说在遍历的时候再去取到指定的值，从代码上来看，内存消耗相对于之前来说就非常小了。

超融合服务器私有云 php协程curl php协程扩展关于php的代码关于php的问题

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/25603.html

python协程与golang协程的区别

摘要：进程线程和协程进程的定义进程，是计算机中已运行程序的实体。协程和线程的关系协程是在语言层面实现对线程的调度，避免了内核级别的上下文消耗。和都引入了消息调度系统模型，来避免锁的影响和进程线程开销大的问题。进程、线程和协程进程的定义：进程，是计算机中已运行程序的实体。程序本身只是指令、数据及其组织形式的描述，进程才是程序的真正运行实例。线程的定义：操作系统能够进行运算调度的最小单...

csRyan 2019-07-31 10:23 评论0 收藏0
【宇润日常疯测-007】Swoole 协程与传统 fpm 同步模式比较

摘要：初识协程执行结果协程与同步模式比较我们一直在说协程适合用于密集场景，在同样的硬件配置环境下，它会比传统的同步模式承载更多的访问量。假设一次查询为，在传统同步模式下，当前进程在这的时间里，是不能做其它操作的。同步模式，耗费左右的是。如果说数组是 PHP 的精髓，数组玩得不6的，根本不能算是会用PHP。那协程对于 Swoole 也是同理，不理解协程去用 Swoole，那就是在瞎用。首先...

henry14 2019-07-01 12:39 评论0 收藏0
谈谈Python协程技术的演进

摘要：事件循环是异步编程的底层基石。对事件集合进行轮询，调用回调函数等一轮事件循环结束，循环往复。协程直接利用代码的执行位置来表示状态，而回调则是维护了一堆数据结构来处理状态。时代的协程技术主要是，另一个比较小众。 Coding Crush Python开发工程师主要负责岂安科技业务风险情报系统redq。引言 1.1. 存储器山存储器山是 Randal Bryant 在《深入...

zhiwei 2019-07-31 11:02 评论0 收藏0
Python 学习笔记关于协程

摘要：协程定义协程是指一个过程，这个过程与调用方协作，产出由调用方提供的值。当得到控制权时，会阻塞，同时等待终止。终止协程的方法该方法致使生成器在暂停的表达式处抛出异常。协程定义：协程是指一个过程，这个过程与调用方协作，产出由调用方提供的值。（协程中必定含有一条yield语句）协程与生成器类似，都是定义体内包含yield关键字的函数。不过，在协程中，yield通常出现在表达式的右边（例...

VishKozus 2019-07-30 17:40 评论0 收藏0
Python 中的进程、线程、协程、同步、异步、回调

摘要：进程和线程究竟是什么东西传统网络服务模型是如何工作的协程和线程的关系和区别有哪些过程在什么时间发生在刚刚结束的上海站，来自七牛云存储的高级工程师许智翔带来了关于的分享中的进程线程协程同步异步回调。使用红黑树管理就绪队列。进程和线程究竟是什么东西？传统网络服务模型是如何工作的？协程和线程的关系和区别有哪些？IO过程在什么时间发生？在刚刚结束的 PyCon2014 上海站，来自七牛云...

Forest10 2019-07-24 17:48 评论0 收藏0