parallel-functions/docs/index.md

66 lines
2.7 KiB
Markdown
Raw Normal View History

2017-12-14 00:30:25 +01:00
---
title: Introduction
permalink: /
---
`amphp/parallel-functions` is a simplifying layer on top of [`amphp/parallel`](https://github.com/amphp/parallel).
It allows parallel code execution by leveraging threads or processes, depending on the installed extensions.
All data sent to / received from the child processes / threads must be serializable using PHP's `serialize()` function.
2017-12-14 00:30:25 +01:00
{:.warning}
> This library uses [`opis/closure`](https://github.com/opis/closure) to serialize closures, so its restrictions apply.
> If serialization of a particular closure doesn't work, you can always write an autoloadable function and call that by name instead.
{:.note}
> PHP's resources aren't serializable and will silently be casted to integers on serialization.
2017-12-14 00:30:25 +01:00
## Installation
This package can be installed as a [Composer](https://getcomposer.org/) dependency.
```bash
composer require amphp/parallel-functions
```
## Usage
Like all other `amphp` libraries, this library works in a fully asynchronous world.
It returns promises as placeholders for future results of operations.
2017-12-14 00:30:25 +01:00
You don't need to know any details to use this library in traditional, fully synchronous applications.
All you need is wrapping every function returning an [`Amp\Promise`](https://amphp.org/amp/promises/) with [`Amp\Promise\wait()`](https://amphp.org/amp/promises/miscellaneous#wait).
2017-12-14 00:30:25 +01:00
```php
<?php
use Amp\Promise;
2017-12-14 18:04:11 +01:00
use function Amp\ParallelFunctions\parallelMap;
2017-12-14 00:30:25 +01:00
2017-12-14 18:04:11 +01:00
$values = Promise\wait(parallelMap([1, 2, 3], function ($time) {
2017-12-14 00:30:25 +01:00
\sleep($time); // a blocking function call, might also do blocking I/O here
return $time * $time;
}));
```
### `parallel()`
`Amp\ParallelFunctions\parallel(callable): callable` wraps a [`callable`](https://secure.php.net/callable), so it's executed in another thread / process on invocation.
All arguments have to be serializable.
2017-12-14 00:30:25 +01:00
Currently this function only supports a direct string as function name or instances of [`\Closure`](https://secure.php.net/Closure).
Support for other [`callable`](https://secure.php.net/callable) types might be added in the future.
2017-12-14 00:30:25 +01:00
2017-12-14 18:04:11 +01:00
### `parallelMap()`
2017-12-14 00:30:25 +01:00
`Amp\ParallelFunctions\parallelMap(array, callable): Promise` works similar to [`array_map()`](https://secure.php.net/array_map), but has a different signature.
It accepts only one array instead of being variadic.
It's thereby consistent with [`parallelFilter()`](#parallelfilter).
2017-12-14 00:30:25 +01:00
Restrictions of [`Amp\ParallelFunctions\parallel()`](#parallel) apply.
2017-12-14 00:30:25 +01:00
2017-12-14 18:04:11 +01:00
### `parallelFilter()`
2017-12-14 00:30:25 +01:00
`Amp\ParallelFunctions\parallelFilter(array, callable, int): Promise` works like [`array_filter()`](https://secure.php.net/array_filter), but returns a promise and executes in parallel.
2017-12-14 00:30:25 +01:00
Restrictions of [`Amp\ParallelFunctions\parallel()`](#parallel) apply.