php多进程编程spatie/async

<?php
require './vendor/autoload.php';

use Spatie\Async\Pool;
use GuzzleHttp\Client;

$stime = microtime(true); //获取程序开始执行的时间
echo "初始: " . round(memory_get_usage() / 1024 / 1024, 2) . ' MB' . "\n";

// 业务逻辑
$d = []; //存储数据使用

//100次curl 请求
$pool = Pool::create();
$client = new Client();
foreach (range(1, 99) as $i) {
    $pool[] = async(function () use ($i, $client) {

        $response = $client->get('https://www.xxx.cn/api/getTemplateLogInfo', [
        ]);
        $output = $response->getBody()->getContents();
        $d[] = $output;
        return $output;
    })->then(function ($output) use (&$d) {
        $d[] = $output;
    });
}
await($pool);



//foreach (range(1, 99) as $i) {
//
//        $j = curlGet();
//
//        $d[] = $j;
//
//}


$etime = microtime(true);//获取程序执行结束的时间
$total = $etime - $stime;   //计算差值
echo "[页面执行时间：{$total} ]秒" . "\n";
echo "使用: " . round(memory_get_usage() / 1024 / 1024, 2) . ' MB' . "\n";// 获取运行时间 和 占用内存
var_dump($d);
function curlGet()
{
    $client = new Client();
    $response = $client->get('https://www.xxx.cn/api/getTemplateLogInfo', [
    ]);
    $content = $response->getBody()->getContents();
    return $content;
}
Copy