本文将解决在使用 Amp 框架进行并发编程时，特别是在循环中使用 Promises 时遇到的问题。通过一个实际的下载场景示例，展示了如何正确地使用 Amp\Promise\all() 来并发执行多个 Promise，并提供了一种解决 Promise 在循环中不返回或抛出异常的方案，帮助开发者更好地理解和应用 Amp 的异步编程模型。
在使用 Amp 框架进行异步编程时，经常会遇到需要在循环中并发执行多个任务的场景。例如，从多个 URL 下载数据，或者处理大量数据块。然而，直接在循环中使用 Amp\Promise\all() 可能会遇到一些问题，例如 Promise 不返回结果或者没有抛出异常，导致程序hang住。
下面的示例代码模拟了一个下载场景，将一个大文件分割成多个 chunk，然后并发下载这些 chunk：
chunkCount + 20; $i++) {
$start = $i * $this->chunkSize;
$end = ($i + 1) * $this->chunkSize;
if ($i == $this->chunkCount - 1) {
$end = $this->size;
}
$chunks[] = (object) ['id' => ($i + 1), 'start' => $start, 'end' => $end, 'path' => $this->path . "/" . $i];
}
$chunkedChunks = array_chunk($chunks, $this->connections);
foreach ($chunkedChunks as $key => $chunkedChunk) {
$urls = [
'https://secure.php.net',
'https://amphp.org',
'https://github.com',
];
$promises = [];
foreach ($urls as $url) {
$promises[$url] = \Amp\call(function() use ($url) {
$deferred = new Deferred();
Loop::delay(3 * 1000, function () use ($url, $deferred) {
$deferred->resolve($url);
});
return $deferred->promise();
});
}
$responses = yield Promise\all($promises);
foreach ($responses as $url => $response) {
\printf("Read %d bytes from %s\n", \strlen($response), $url);
}
}
}
public function runDownload() {
Loop::run(function () {
yield $this->download();
});
}
}
// 使用示例
Loop::run(function () {
$downloader = new Downloader(null);
yield \Amp\call(function() use ($downloader) {
$downloader->download();
});
});在这个例子中，我们首先将要下载的内容分割成多个 chunk，然后将这些 chunk 分组，每组包含一定数量的 chunk，数量由 $this->connections 决定。然后，我们遍历这些分组，为每个分组创建一组 Promise，并使用 Amp\Promise\all() 来并发执行这些 Promise。
问题分析与解决方案
Android文档-开发者指南-第一部分：入门-中英文对照版 Android提供了丰富的应用程序框架，它允许您在Java语言环境中构建移动设备的创新应用程序和游戏。在左侧导航中列出的文档提供了有关如何使用Android的各种API来构建应用程序的详细信息。第一部分：Introduction(入门) 0、Introduction to Android(引进到Android) 1、Application Fundamentals(应用程序基础) 2、Device Compatibility(设备兼容性) 3、
最初的代码中，yield Amp\Promise\all($promises) 并没有返回任何结果，也没有抛出任何异常。这可能是因为 Promise 的执行上下文出现问题。
解决方案是将整个 foreach 循环块包裹在一个 Amp\call() 中，这样可以确保循环中的代码在正确的 Amp 协程上下文中执行。修改后的代码如下：
chunkCount + 20; $i++) {
$start = $i * $this->chunkSize;
$end = ($i + 1) * $this->chunkSize;
if ($i == $this->chunkCount - 1) {
$end = $this->size;
}
$chunks[] = (object) ['id' => ($i + 1), 'start' => $start, 'end' => $end, 'path' => $this->path . "/" . $i];
}
$chunkedChunks = array_chunk($chunks, $this->connections);
yield \Amp\call(function() use ($chunkedChunks) {
foreach ($chunkedChunks as $key => $chunkedChunk) {
$urls = [
'https://secure.php.net',
'https://amphp.org',
'https://github.com',
];
$promises = [];
foreach ($urls as $url) {
$promises[$url] = \Amp\call(function() use ($url) {
$deferred = new Deferred();
Loop::delay(3 * 1000, function () use ($url, $deferred) {
$deferred->resolve($url);
});
return $deferred->promise();
});
}
$responses = yield Promise\all($promises);
foreach ($responses as $url => $response) {
\printf("Read %d bytes from %s\n", \strlen($response), $url);
}
}
});
}
public function runDownload() {
Loop::run(function () {
yield $this->download();
});
}
}
// 使用示例
Loop::run(function () {
$downloader = new Downloader(null);
yield \Amp\call(function() use ($downloader) {
$downloader->download();
});
});注意事项与总结
- 协程上下文： 在使用 Amp 进行并发编程时，务必确保代码在正确的协程上下文中执行。Amp\call() 可以用来创建一个新的协程，并确保代码在其中执行。
- 错误处理： 在并发执行 Promise 时，需要注意错误处理。可以使用 try-catch 块来捕获 Promise 执行过程中抛出的异常。
- 性能优化： 并发连接数 $this->connections 需要根据实际情况进行调整，以达到最佳的下载速度。过多的并发连接可能会导致服务器压力过大，而过少的并发连接可能会导致下载速度过慢。
通过本文的介绍，相信你已经掌握了在循环中使用 Amp Promises 的基本方法，并能够解决 Promise 不返回或抛出异常的问题。在实际开发中，可以根据具体场景进行调整和优化，以达到最佳的并发性能。
