mirror_php/parallel
1
0
Fork 0
mirror of https://github.com/amphp/parallel.git synced 2025-01-17 20:58:36 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update example (#140)

Browse Source
This commit is contained in:
Gemorroj 2021-12-01 10:28:40 +03:00 committed by GitHub
parent 7fde6f1308
commit 09ef95a138
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
README.md
View File

@ -30,8 +30,9 @@ The basic usage of this library is to submit blocking tasks to be executed by a
require __DIR__ . '/../vendor/autoload.php';
use Amp\Future;
use Amp\Parallel\Worker;
use Amp\Promise;
use function Amp\launch;
$urls = [
'https://secure.php.net',
@ -39,12 +40,12 @@ $urls = [
'https://github.com',
];
$promises = [];
$futures = [];
foreach ($urls as $url) {
$promises[$url] = Worker\enqueueCallable('file_get_contents', $url);
$futures[$url] = launch(fn () => Worker\enqueueCallable('file_get_contents', $url));
}
$responses = Promise\wait(Promise\all($promises));
$responses = Future\all($futures);
foreach ($responses as $url => $response) {
\printf("Read %d bytes from %s\n", \strlen($response), $url);