tleckie/async

异步和并行 PHP

维护者

详细信息

github.com/teodoroleckie/async

主页

源代码

问题

资助包维护！
teodoroleckie
www.paypal.com/donate?business=ZHYA2MTGA4884&currency_code=USD

安装: 12

依赖者: 0

建议者: 0

安全: 0

星星: 3

观察者: 1

分支: 0

开放问题: 0

1.0.6 2021-04-25 10:59 UTC

Requires

Requires (Dev)

Suggests

  • ext-pcntl: Required to use async processes
  • ext-posix: Required to use async processes

MIT bf42c8ed47d9ca1580cae9fbd93892288801d9ad

  • Teodoro Leckie Westberg <teodoroleckie.woop@gmail.com>

asynctleckieasynchronous phpparallel php

This package is auto-updated.

Last update: 2024-09-11 14:33:14 UTC

README

Latest Version on Packagist Scrutinizer Code Quality Build Status Total Downloads

安装

您可以通过 composer 安装此包

composer require tleckie/async

用法

<?php

use Tleckie\Async\Async;

$async = new Async();

foreach([1,2,3,4,5,6,7,8,9,10] as $value){

    $async->add(static function() use($value){
    
        sleep(1);
        
        return $value*2;
        
    })->then(static function($value){
        
        var_dump($value);
        
    })->catch(static function(\Exception $exception){
    
        var_dump($exception->getMessage());
    });
}

$async->wait();

捕获异常

<?php

use Tleckie\Async\Async;

$async = new Async();

$async->add(static function (){

    throw new \Exception('Error...');

})->then(static function ($value) {

})->catch(static function ($exception) {

    var_dump($exception);
});

$async->wait();