天真地等待異步PHP中的內(nèi)部循環(huán)導(dǎo)致連續(xù)執(zhí)行，擊敗並發(fā)。 2。在AMP中，使用AMP \ Promise \ all（）並行運(yùn)行所有操作並等待完成，或者AMP \ Iterator \ forterable（）在到達(dá)時(shí)處理結(jié)果； 3。在ReactPhp中，使用React \ Promise \ all（）進(jìn)行並行執(zhí)行或具有並發(fā)限制的PromiseMap :: map（）以控制同時(shí)操作； 4。始終避免阻止內(nèi)部循環(huán)，使用適當(dāng)?shù)某兄Z組合器處理錯(cuò)誤，通過流式傳輸結(jié)果來管理背壓，並寧願(yuàn)等待整個(gè)操作而不是單個(gè)任務(wù)以保持性能和控制流程。

在使用AMP或ReactPHP等異步PHP框架時(shí)，與傳統(tǒng)PHP的最大心理轉(zhuǎn)變之一是處理循環(huán) - 尤其是在處理內(nèi)部異步操作時(shí)。在同步PHP中，一個(gè)foreach循環(huán)很簡(jiǎn)單：為每個(gè)項(xiàng)目運(yùn)行一些代碼，一個(gè)接一個(gè)。但是，在異步環(huán)境中，天真地等待循環(huán)內(nèi)部會(huì)導(dǎo)致意外的性能瓶頸，甚至?xí)?dǎo)致控制流量破裂。

讓我們分解如何在AMP和ReactPHP中正確處理異步迭代的方法，以及為什麼通常的方法不總是有效。

為什麼常規(guī)循環(huán)在異步代碼中失敗

在同步PHP中，您可能會(huì)寫：

 foreach（$ urls as $ url）{
    $ result = file_get_contents（$ url）;
    迴聲$結(jié)果；
}

但是在異步代碼中，如果您嘗試以下操作：

 //不要這樣做
foreach（$ urls as $ url）{
    $ result = yart $ httpclient->請(qǐng)求（$ url）; // amp
    迴聲$結(jié)果；
}

您正在等待每個(gè)請(qǐng)求依次等待- 下一個(gè)請(qǐng)求直到上一個(gè)請(qǐng)求才能啟動(dòng)。這殺死了並發(fā)的好處。

更糟糕的是：在ReactPHP中，您根本無法yield ，並且不允許阻止等待。 then()回調(diào) - 循環(huán)迅速變得難以管理。

在放大器中處理異步迭代

AMP提供了正確管理異步迭代的工具。關(guān)鍵是避免在循環(huán)主體內(nèi)部yield ，而是同時(shí)啟動(dòng)所有操作，然後等待它們。

使用Amp\Promise\all()進(jìn)行並行執(zhí)行

使用AMP \ Promise;
使用AMP \ http \ client \ client;
使用AMP \ http \ client \ request;

$ promises = [];

foreach（$ urls as $ url）{
    $ promises [] = amp \ call（fn（）=> $ httpclient-> request（$ url） - > getBody（））;
}

$結(jié)果=收益承諾\ all（$ propisises）;

foreach（$結(jié)果為$ result）{
    迴聲$結(jié)果；
}

這啟動(dòng)了所有HTTP請(qǐng)求並行，然後等待所有請(qǐng)求完成。

?最佳：當(dāng)您想要處理所有項(xiàng)目並可以等待最慢時(shí)。

使用Amp\Iterator進(jìn)行流式結(jié)果

如果要處理結(jié)果時(shí)處理結(jié)果，請(qǐng)使用Amp\ConcurrentIterator ：

 $ promises = [];
foreach（$ urls as $ url）{
    $ promises [] = amp \ call（fn（）=> $ httpclient-> request（$ url） - > getBody（））;
}

$ iterator = amp \ iterator \ forterable（$ promises）;

while（產(chǎn)生$ iterator-> Advance（））{
    $ result = $ iterator-> getCurrent（）;
    迴聲“ got：$ result \ n”;
}

在每個(gè)諾言都消失後，輸出會(huì)產(chǎn)生結(jié)果，而無需等待所有承諾。

在ReactPHP中處理異步迭代

ReactPHP使用回調(diào)和React\Promise\PromiseInterface 。沒有yield ，因此您可以建立承諾鍊或使用實(shí)用程序功能。

使用React\Promise\all()進(jìn)行並行執(zhí)行

使用React \ Promise;

$ promises = [];

foreach（$ urls as $ url）{
    $ promises [] = $ httpclient->請(qǐng)求（'get'，$ url） - >
        fn（$ wenspy）=> $ revyse--> getbody（） - > getContents（）
    ）；
}

承諾\ all（$ promises） - > then（function（$結(jié)果）{
    foreach（$結(jié)果為$ result）{
        迴聲$結(jié)果；
    }
}）;

像AMP的all()一樣，這並在所有完成時(shí)都可以並行運(yùn)行。

?適用於批處理處理，但會(huì)阻止輸出直到最後一項(xiàng)。

使用React\Promise\some()或map()進(jìn)行更多控制

要使用極限（例如，最大3並發(fā)）處理，請(qǐng)使用clue/reactphp-mq或react/promise-maps （第三方）：

使用React \ Promise \ PromiseMap;

$ resucts = PromiseMap :: map（$ urls，function（$ url）使用（$ httpclient）{
    返回$ httpclient->請(qǐng)求（'get'，$ url）
         - >然後（fn（$ res）=> $ res-> getBody（） - > getContents（））;
}，['contrency'=> 3]）;

$結(jié)果 - >然後（功能（$ hodies）{
    foreach（$ bodies as $ body）{
        Echo $ body;
    }
}）;

這將限制在一次3個(gè)請(qǐng)求中的並發(fā)限制 - 非常適合避免壓倒性服務(wù)器。

關(guān)鍵要點(diǎn)

• ?永遠(yuǎn)yield在循環(huán)中期望並發(fā)。
• ?當(dāng)您需要所有結(jié)果並且可以等待時(shí)，請(qǐng)使用Promise\all() 。
• ?使用帶有並發(fā)限制（ReactPHP）的流迭代器（AMP）或map()進(jìn)行更好的流量控制。
• ?過程結(jié)果在可能的情況下到達(dá) - 提高響應(yīng)能力。
• ??考慮記憶：緩衝成千上萬的承諾可能很昂貴。

對(duì)於現(xiàn)實(shí)世界的使用，請(qǐng)考慮：

• 錯(cuò)誤處理：使用Promise\any() ， some()或包裝在try/catch （amp）或.catch() （reactphp）中。
• 背壓：流結(jié)果，而不是收集所有內(nèi)容。
• 取消：AMP支持可取消的承諾；反應(yīng)較少。

異步迭代不是要替換foreach ，而是關(guān)於重新思考何時(shí)以及如何等待。

基本上，不要循環(huán)等待 - 等待循環(huán)。

以上是異步迭代：在AMP或ReactPHP上下文中查看循環(huán)的詳細(xì)內(nèi)容。更多資訊請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！