Amphp 并行是如何工作的？

Question

我正在阅读有关 amphp，我对并行有疑问

示例代码：

<?php

require __DIR__ . '/vendor/autoload.php';

$client = new Amp\Artax\DefaultClient;
$promises = [];

$urls = [
    "http://google.com.br",
    "http://facebook.com.br",
    "http://xat.com/",
    "http://kobra.ninja/",
    "http://wikipedia.com",
    "http://manualdomundo.com.br",
    "http://globo.com",
    "http://gmail.com"
];

foreach ($urls as $url) {
    $promises[$url] = Amp\call(function () use ($client, $url) {
        // "yield" inside a coroutine awaits the resolution of the promise
        // returned from Client::request(). The generator is then continued.
        $response = yield $client->request($url);

        // Same for the body here. Yielding an Amp\ByteStream\Message
        // buffers the entire message.
        $body = yield $response->getBody();
        echo $url;
        return $url;
    });
}

$responses = Amp\Promise\wait(Amp\Promise\all($promises));

这段代码是全部运行 curl，还是等待 1 执行另一个？

Answer 1

从Amp codebase 可以看出，它会在同一个事件循环中运行您的所有请求。

鉴于您的请求正在被产生 (yield $client->request($url))，并且它们是在同一个事件循环中产生的，它们被同时分派。

我建议您阅读this article through，特别是“异步开发：Amp 框架的工作原理”部分。我认为这将使引擎在幕后的工作方式更加清晰。

希望这对您有所帮助。干杯! :)

Answer 2

这是使用stream_select 功能。它没有以您所想的传统方式并行运行。它的工作原理是注册一个回调，以便在流可读/可写后调用，然后在您等待的特定承诺完成时返回。同时解决的所有其他承诺都已完成并缓存在各自的承诺中，等待您使用yield 或Promise::onResolve 解包值。 Amp's event loop 负责管理多个套接字并为您处理并发。

如果您想了解其工作原理的基本示例，我在 GitHub 上放了一个示例项目，它是两个类，但基于 Curl 而不是 stream_select：https://github.com/kwhat/requestful

first 7 methods 是设置 Promise 接口所需的全部内容。这里所有的魔法都基于传递给构造函数的两个回调以及 then/cancel 回调的包装器。

sendRequestAsync 方法是创建并发 Curl 请求的方式。魔术都发生在任何 promise 上的 wait() 回调中，它调用 anonymous function，实习生在循环中调用 tick 方法。 tick() 方法解决了所有的承诺，不管你叫哪个等待。