PHP全局作用域下Amp异步并行执行时全局常量未定义如何解决

问题原因 #

amphp/parallel-functions 底层依赖的 parallelMap 会启动独立的PHP Worker子进程处理任务，子进程默认仅加载composer自动加载器，父进程运行期定义的常量、全局变量、非自动加载的文件内容都不会同步到子进程，因此会出现常量未定义的报错。

解决方案 #

可根据你的业务场景选择任意一种方案解决：

方案1：将常量定义纳入composer自动加载 #

如果你的常量是全局通用的，推荐通过composer的文件自动加载配置让Worker进程启动时自动加载常量定义：

1. 将常量定义放到独立文件中，比如src/constants.php

   <?php
   define('API_TOKEN', 'my-value');
   

2. 编辑composer.json新增自动加载文件配置

   {
       "autoload": {
           "files": ["src/constants.php"]
       }
   }
   

3. 执行命令更新自动加载配置

   composer dump-autoload
   

方案2：自定义Worker启动引导文件 #

如果不想修改全局自动加载配置，可以自定义Worker的启动脚本显式加载需要的内容：

1. 新建Worker引导文件worker-bootstrap.php

   <?php
   require __DIR__ . '/vendor/autoload.php';
   // 直接定义常量或者加载你的常量定义文件
   define('API_TOKEN', 'my-value');
   // 或者加载原有常量文件：require __DIR__ . '/path/to/constants.php';
   

2. 业务代码中自定义默认Worker池，指定引导文件

   use Amp\Parallel\Worker\DefaultPool;
   use Amp\Parallel\Worker\Pool;
   use function Amp\ParallelFunctions\parallelMap;
   use function Amp\Promise\wait;
   
   $pool = new DefaultPool(
       workerFactory: null,
       bootstrapper: __DIR__ . '/worker-bootstrap.php'
   );
   Pool::setDefault($pool);
   
   // 原有业务逻辑无需修改
   $result = wait( parallelMap( $myArray, function($item) use ($api) {
       return $api->call_api( $item );
   } ) );
   

方案3：显式传参避免依赖全局常量（最推荐） #

直接将常量值作为参数传入闭包，同时改造call_api方法支持传入token参数，完全避免子进程依赖全局状态，兼容性最高：

$token = API_TOKEN;
$result = wait( parallelMap( $myArray, function($item) use ($api, $token) {
    // 改造call_api方法，接收token参数替代全局常量调用
    return $api->call_api( $item, $token );
} ) );

注意事项 #

• 传入parallelMap的闭包内不要依赖父进程的全局状态，所有需要的变量必须显式通过use传入
• 闭包内不要引用资源类型（比如数据库连接、文件句柄等），这类内容无法序列化会抛出错误

内容的提问来源于stack exchange，提问作者ecairol