README

• Requirements
• Usage
• Installation
• License
• Author

Requirements

• UNIX
• CGI or CLI version of PHP5.4+
• Compiled with --enable-pcntl

Usage

Run multiple tasks asynchronously

<?php use KzykHys\Parallel\Parallel; require __DIR__ . "/vendor/autoload.php"; $parallel = new Parallel(); $parallel->run([ function () { echo "task#1 start\n"; sleep(2); echo "task#1 end\n"; }, function () { echo "task#2 start\n"; sleep(3); echo "task#2 end\n"; } ]); echo "Done\n";

will outputs like this:

task#1 start task#2 start task#1 end task#2 end Done 

Get an array containing all the results of each job

Notes:

1. Internally unix socket is used to receive a value from child process.
2. The result must be serializable.

<?php use KzykHys\Parallel\Parallel; require __DIR__ . "/vendor/autoload.php"; $parallel = new Parallel(); $values = $parallel->values([ function () { return 'item'; }, 'foo' => function () { // return value must be serializable return new \DateTime('2013-01-01'); } ]); var_dump($values);

will output like this:

array(2) { [0] => string(4) "item" 'foo' => class DateTime#6 (3) { public $date => string(19) "2013-01-01 00:00:00" public $timezone_type => int(3) public $timezone => string(10) "Asia/Tokyo" } } 

Process multiple values asynchronously

<?php use KzykHys\Parallel\Parallel; require __DIR__ . "/vendor/autoload.php"; $parallel = new Parallel(); $parallel->each(['a', 'b'], function ($str) { echo "start task with '$str'\n"; sleep(3); echo "finish task with '$str'\n"; });

Get an array containing all the results of each job

Notes:

1. Internally unix socket is used to receive a value from child process.
2. The result must be serializable.

<?php use KzykHys\Parallel\Parallel; require __DIR__ . "/vendor/autoload.php"; $parallel = new Parallel(); $values = $parallel->map([1, 2, 3], function ($value) { return $value * 2; }); var_dump($values);

will output like this:

array(3) { [0] => int(2) [1] => int(4) [2] => int(6) } 

Java like Thread and Runnable

<?php use KzykHys\Thread\Runnable; use KzykHys\Thread\Thread; require __DIR__ . "/vendor/autoload.php"; class Job implements Runnable { public function run() { // do your job } } class AnotherJob extends Thread { public function run() { // do your another job } } $thread1 = new Thread(new Job()); $thread2 = new AnotherJob(); $thread1->start(); $thread2->start(); $thread1->wait(); $thread2->wait();

Installation

Update or create composer.json.

{ "require": { "kzykhys/parallel": "dev-master" } }

License

The MIT License

Author

Kazuyuki Hayashi (@kzykhys)