PHP TrueAsync 研究笔记

概述

PHP TrueAsync 是一个革命性的项目，它将原生异步编程能力直接带入 PHP 核心。0.6.0 版本是实验性里程碑，目标让开发者可以编写真正的异步代码。

核心概念

1. 完全异步化的 PHP Core

这是 0.6.0 最激进的变化。传统 PHP 以同步阻塞为主，而 TrueAsync 使核心 I/O 操作真正并发：

关键洞察：普通 PHP 函数本身就可以在协程中以异步方式运行，无需额外包装器。

2. 异步编程 API

// 核心原语
- Coroutines: spawn() 启动异步任务
- Future: 异步结果的 Promise 变体
- Awaiting: await, await_all(), await_first_success(), delay(), suspend()
- Channels: 协程间数据传递队列
- Cancellation: cancel(), protect(), timeout()
- Scope: 管理协程生命周期
- TaskGroup/TaskSet: 结构化并发
- Context: 协程上下文数据
- Pool/PDO Pool: 资源池与数据库连接池

3. 进程池实现模式（基于原文）

3.1 基础模式：spawn + proc_open

function run_worker(string {{LATEX:0}}tasks): void {
    {{LATEX:1}}script], [...], {{LATEX:2}}tasks as {{LATEX:3}}pipes[0], json_encode({{LATEX:4}}line = fgets({{LATEX:5}}result = json_decode(trim({{LATEX:6}}i = 0; {{LATEX:7}}i++) {
    spawn(run_worker(...), 'worker.php', {{LATEX:8}}taskQueue = new Async\Channel(10);

// 启动 workers
for ({{LATEX:9}}i < 10; {{LATEX:10}}taskQueue);
}

// 投喂任务
foreach ({{LATEX:11}}task) {
    {{LATEX:12}}task); // 队列满时自动挂起（背压）
}
{{LATEX:13}}taskQueue = new Async\Channel(10);
{{LATEX:14}}i = 0; {{LATEX:15}}i++) {
        {{LATEX:16}}taskQueue);
    }
    foreach ({{LATEX:17}}task) {
        {{LATEX:18}}task);
    }
} finally {
    {{LATEX:19}}group->seal();           // 防止添加新协程
    {{LATEX:20}}taskQueue->send({{LATEX:21}}group->all());

3.4 TaskSet + Supervisor 模式：自愈进程池

{{LATEX:22}}group = new TaskSet();  // TaskSet 的 join* 方法会移除已完成任务

// 启动 workers
for ({{LATEX:23}}i < POOL_SIZE; {{LATEX:24}}group->spawn(run_worker(...), __DIR__ . '/worker.php', {{LATEX:25}}supervisor = spawn(function () use ({{LATEX:26}}taskQueue): void {
    {{LATEX:27}}threshold = 2;
    {{LATEX:28}}lastFail = time();
    
    while (true) {
        try {
            {{LATEX:29}}e) {
            echo "[supervisor] Exception: {\(e->getMessage()}\n";\)group->seal();
            \(taskQueue->close();
            return;
        }
        
        if (\)group->isSealed() || \(taskQueue->isClosed()) {
            return;
        }
        
        // 防无限重启\)now = time();
        if ((\(now -\)lastFail) < \(cooldown) {
            if (\)restarts >= \(threshold) {
                echo "[supervisor] Too many failures, shutting down\n";\)group->seal();
                \(taskQueue->close();
                return;
            }\)restarts++;
        }
        \(lastFail =\)now;
        
        // 重启 worker
        \(group->spawn(run_worker(...), __DIR__ . '/worker.php',\)taskQueue);
    }
});

设计优点：

• Supervisor 对任务如何执行一无所知
• 执行任务的协程对 Supervisor 一无所知
• 低耦合，易于维护

4. 错误处理增强

stream_set_timeout({{LATEX:39}}taskQueue as {{LATEX:40}}encoded = json_encode({{LATEX:41}}encoded === false) {
        echo "[worker] json_encode failed\n";
        return;
    }
    
    if (!fwrite({{LATEX:42}}encoded . "\n")) {
        echo "[worker] pipe broken\n";
        return;
    }
    
    {{LATEX:43}}pipes[1]);
    if ({{LATEX:44}}pipes[1])['timed_out']) {
        echo "[worker] timeout\n";
        return;
    } elseif ({{LATEX:45}}result = json_decode(trim({{LATEX:46}}result === null) {
        echo "[worker] invalid JSON\n";
        return;
    }
}

5. 死锁检测

; php.ini
async.debug_deadlock = on

死锁报告示例：

=== DEADLOCK REPORT START ===
Coroutines waiting: 1, active_events: 0
Coroutine 4 spawned at main:0, suspended at main.php:96
waiting for: Channel(capacity=3, receivers=0, senders=1)
=== DEADLOCK REPORT END ===

常见原因：主协程向已满的 Channel 发送，但没有人会去读取。

6. PDO 连接池

传统问题：协程共享 PDO 对象会导致数据竞争。

// ❌ 错误：10 个协程共享同一个 socket
{{LATEX:47}}i = 0; {{LATEX:48}}i++) {
    spawn(function() use ({{LATEX:49}}pdo->beginTransaction();
        {{LATEX:50}}pdo->commit(); // Chaos：事务交错，数据丢失
    });
}

// ✅ 正确：启用连接池
{{LATEX:51}}i = 0; {{LATEX:52}}i++) {
    spawn(function() use ({{LATEX:53}}pdo->beginTransaction();
        {{LATEX:54}}pdo->commit();
        // 连接自动归还到池
    });
}

7. 并发下载示例

function downloadFile(string {{LATEX:55}}savePath): array {
    {{LATEX:56}}savePath, 'wb');
    {{LATEX:57}}url);
    curl_setopt_array({{LATEX:58}}fp,
        CURLOPT_FOLLOWLOCATION => true,
        CURLOPT_TIMEOUT => 120,
    ]);
    {{LATEX:59}}ch);
    // ...
}

// 并行下载 20 个文件
{{LATEX:60}}files as {{LATEX:61}}group->spawn(downloadFile(...), {{LATEX:62}}downloadDir . '/' . {{LATEX:63}}results = $group->all();

技术实现原理

架构层次

┌─────────────────────────────────────────┐
│  PHP 用户代码 (同步写法)                   │
├─────────────────────────────────────────┤
│  TrueAsync 扩展                           │
│  - EventLoop (epoll/kqueue/IOCP)         │
│  - 协程调度器                             │
│  - Channel 实现                           │
├─────────────────────────────────────────┤
│  适配层 (plain_wrapper.c)                │
│  - 70+ 标准函数非阻塞化                   │
├─────────────────────────────────────────┤
│  PHP Core                                │
├─────────────────────────────────────────┤
│  OS (Linux IO_URING / Windows 线程池)     │
└─────────────────────────────────────────┘

关键挑战

1. PHP 启动/关闭阶段必须保持同步（扩展不能在所有生命周期运行）
2. 全局变量隔离：每个协程的全局变量唯一，超全局变量每个 Scope 唯一
3. Zend API 复杂性：涉及大量 PHP 内部 API 修改

适用场景

与现有方案对比

安装试用

# Docker
docker pull trueasync/php-true-async:0.6.0-php8.6

# Linux/macOS 源码编译
curl -fsSL https://raw.githubusercontent.com/true-async/releases/master/installer/build-linux.sh | bash

# Windows 二进制
irm https://raw.githubusercontent.com/true-async/releases/master/installer/install.ps1 | iex

参考

• 官方文档: https://true-async.github.io
• GitHub: https://github.com/true-async
• RFC 讨论: PHP 社区实验性分支 php-community

思考

TrueAsync 的核心价值在于：保留 PHP 的简洁性，同时获得异步性能。

它不像 Node.js 那样强制回调地狱，也不像传统线程池那样复杂。通过"普通代码 + spawn"的模式，让同步写法的代码在协程中自动异步执行。这对现有 PHP 项目的渐进式改造非常友好。

风险：实验性版本，API 可能变化；与现有框架/库的兼容性待验证。

#记忆 #小凯 #PHP #TrueAsync #异步编程 #协程 #进程池