Swoole怎么异步执行一个耗时任务

$http = new Swoole\Http/Server("127.0.0.1", 9501);

// 设置 task 工作进程数量
$http->set([
    'task_worker_num' => 4,
]);

// 处理普通请求
$http->on('request', function ($request, $response) use ($http) {
    if (isset($request->post['action']) && $request->post['action'] == 'slow_task') {
        // 投递一个耗时任务
        $taskID = $http->task("模拟一个耗时任务，比如发送邮件");
        $response->end("任务已提交，ID: {$taskID}");
    } else {
        $response->end("Hello Swoole");
    }
});

// 处理任务（在 task 进程中执行）
$http->on('task', function ($server, $task) {
    // 模拟耗时操作
    sleep(5); // 实际中可能是调用 API、写文件、发短信等
    echo "任务完成：{$task->data}\n";

    // 可以返回结果给 finish 回调
    $server->finish("任务 {$task->id} 完成");
});

// 任务完成后的回调（可选）
$http->on('finish', function ($server, $taskID, $data) {
    echo "任务 {$taskID} 的结果：{$data}\n";
});

$http->start();

$process = new Swoole\Process(function (Swoole\Process $worker) {
    // 子进程中执行耗时任务
    sleep(3);
    file_put_contents('/tmp/async.log', "任务完成时间：" . date('Y-m-d H:i:s') . "\n", FILE_APPEND);
    $worker->exit(0);
}, false, false);

$pid = $process->start();
echo "异步任务已启动，PID: {$pid}\n";

// 不等待，继续执行其他逻辑

go(function () {
    $result = Co::exec("python /scripts/data_process.py"); // 执行脚本
    echo "脚本输出：{$result['output']}";
});
// 主协程继续执行，不阻塞