tiagobutzke / phparallel
简单的多任务库
0.1.1
2015-01-13 21:18 UTC
Requires (Dev)
- phpunit/php-code-coverage: 1.2.*
This package is not auto-updated.
Last update: 2024-09-14 15:37:29 UTC
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
获取包含每个任务结果的数组
注意
- 内部使用 UNIX 套接字从子进程接收值。
- 结果必须是可序列化的。
<?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"; });
获取包含每个任务结果的数组
注意
- 内部使用 UNIX 套接字从子进程接收值。
- 结果必须是可序列化的。
<?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": { "tiagobutzke/phparallel": "0.1.1" } }
许可证
MIT 许可证
作者
Kazuyuki Hayashi (@kzykhys)