README

• 需求
• 用法
• 安装
• 许可证
• 作者

需求

• UNIX
• PHP5.4+的CGI或CLI版本
• 编译时启用 --enable-pcntl

用法

异步运行多个任务

<?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";

输出将类似于以下内容

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

获取包含每个作业结果的数组

注意

1. 内部使用UNIX套接字从子进程接收值。
2. 结果必须是可序列化的。

<?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);

输出将类似于以下内容

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"
  }
}

异步处理多个值

<?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";
});

获取包含每个作业结果的数组

注意

1. 内部使用UNIX套接字从子进程接收值。
2. 结果必须是可序列化的。

<?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);

输出将类似于以下内容

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

类似Java的 Thread 和 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();

安装

更新或创建 composer.json。

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

许可证

MIT许可证

作者

Kazuyuki Hayashi (@kzykhys)