前言
本文主要給大家介紹了關(guān)于PHP中協(xié)程和阻塞的理解與思考，分享出來(lái)供大家參考學(xué)習(xí)，下面話不多說(shuō)了，來(lái)一起看看詳細(xì)的介紹：
進(jìn)程、線程、協(xié)程
關(guān)于進(jìn)程、線程、協(xié)程，有非常詳細(xì)和豐富的博客或者學(xué)習(xí)資源，我不在此做贅述，我大致在此介紹一下這幾個(gè)東西。
- 進(jìn)程擁有自己獨(dú)立的堆和棧，既不共享堆，亦不共享?xiàng)＃M(jìn)程由操作系統(tǒng)調(diào)度。
- 線程擁有自己獨(dú)立的棧和共享的堆，共享堆，不共享?xiàng)＃€程亦由操作系統(tǒng)調(diào)度(標(biāo)準(zhǔn)線程是的)。
- 協(xié)程和線程一樣共享堆，不共享?xiàng)＃瑓f(xié)程由程序員在協(xié)程的代碼里顯示調(diào)度。
PHP中的協(xié)程實(shí)現(xiàn)基礎(chǔ) yield
yield的根本實(shí)現(xiàn)是生成器類，而迭代器類是迭代器接口的實(shí)現(xiàn)：
Generator implements Iterator {
public mixed current ( void ) // 返回當(dāng)前產(chǎn)生的值
public mixed key ( void ) // 返回當(dāng)前產(chǎn)生的鍵
public void next ( void ) // 生成器繼續(xù)執(zhí)行
public void rewind ( void ) // 重置迭代器，如果迭代已經(jīng)開始了，這里會(huì)拋出一個(gè)異常。
// renwind的執(zhí)行將會(huì)導(dǎo)致第一個(gè)yield被執(zhí)行, 并且忽略了他的返回值.
public mixed send ( mixed $value ) // 向生成器中傳入一個(gè)值，并且當(dāng)做 yield 表達(dá)式的結(jié)果，然后繼續(xù)執(zhí)行生成器。如果當(dāng)這個(gè)方法被調(diào)用時(shí)，生成器
// 不在 yield 表達(dá)式，那么在傳入值之前，它會(huì)先運(yùn)行到第一個(gè) yield 表達(dá)式。
public void throw ( Exception $exception ) // 向生成器中拋入一個(gè)異常
public bool valid ( void ) // 檢查迭代器是否被關(guān)閉
public void __wakeup ( void ) // 序列化回調(diào)，拋出一個(gè)異常以表示生成器不能被序列化。
}
以上解析可以參考PHP官方文檔。
http://php.net/manual/zh/clas...
以及這篇詳細(xì)文檔：
http://www.jb51.net/article/39424_all.htm
我就以他實(shí)現(xiàn)的協(xié)程多任務(wù)調(diào)度為基礎(chǔ)做一下例子說(shuō)明并說(shuō)一下關(guān)于我在阻塞方面所做的一些思考。
自定義簡(jiǎn)單定時(shí)執(zhí)行任務(wù)示例：
(此例子必須依賴于以上鳥哥實(shí)現(xiàn)的協(xié)程調(diào)度代碼)
class timer {
private $start = 0; // 定時(shí)開始時(shí)間
private $timer; // 間隔的時(shí)間差，單位秒
private $value = 0; // 產(chǎn)生的結(jié)果值
private $callback; // 異步回調(diào)
private $isEnd = false; // 當(dāng)前定時(shí)器任務(wù)是否結(jié)束
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();
}
}
/**
* 定時(shí)執(zhí)行檢查
*/
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;
}
}
/**
* 模擬阻塞的協(xié)程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();
}
}
/**
* 模擬阻塞的協(xié)程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();
以上實(shí)現(xiàn)的是：
- 產(chǎn)生兩個(gè)任務(wù)，并行執(zhí)行，并且給每個(gè)任務(wù)在執(zhí)行的時(shí)候模擬幾秒鐘的阻塞；
- 讓協(xié)程切換的時(shí)候能順利切換，其中的任務(wù)阻塞不相互影響；
思考：
我為什么要做以上這件事情呢？因?yàn)槲野l(fā)現(xiàn)協(xié)程實(shí)現(xiàn)雖然很強(qiáng)大也很有意思，能讓多任務(wù)并行，但是我在其中一個(gè)任務(wù)里調(diào)用系統(tǒng)函數(shù) sleep() 的時(shí)候,阻塞任務(wù)會(huì)阻止協(xié)程切換，其實(shí)從協(xié)程的實(shí)現(xiàn)原理上來(lái)書也是這么回事。
那么，我也就想模擬協(xié)程阻塞，但是不產(chǎn)生阻塞看是否可行。PHP本身只提供了生成器為協(xié)程調(diào)用提供了支撐，如果不依賴擴(kuò)展，沒有提供多線程的程序?qū)崿F(xiàn)方式，沒有java那么強(qiáng)大，可以開子線程進(jìn)行實(shí)現(xiàn)。