实现PHP多线程的后台任务处理_稳定php多线程怎么实现的后台运行方法

class AsyncTask extends Thread {
    private $data;
    public $result;

    public function __construct($data) {
        $this->data = $data;
    }

    public function run() {
        // 模拟耗时任务
        $this->result = strtoupper($this->data);
        sleep(2);
    }
}

$thread1 = new AsyncTask("task1");
$thread2 = new AsyncTask("task2");

$thread1->start();
$thread2->start();

$thread1->join();
$thread2->join();

echo "结果1: " . $thread1->result . "\n";
echo "结果2: " . $thread2->result . "\n";

function processTask($taskId) {
    echo "进程启动: PID=" . getmypid() . ", 任务ID: $taskId\n";
    sleep(3); // 模拟耗时操作
    echo "任务完成: $taskId\n";
}

$tasks = ['A', 'B', 'C'];
$pids = [];

foreach ($tasks as $task) {
    $pid = pcntl_fork();
    if ($pid == 0) {
        // 子进程执行任务
        processTask($task);
        exit(0);
    } elseif ($pid > 0) {
        // 父进程记录PID
        $pids[] = $pid;
    }
}

// 等待所有子进程结束
foreach ($pids as $pid) {
    pcntl_waitpid($pid, $status);
}

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

while (true) {
    $task = $redis->blPop('task_queue', 5);
    if ($task) {
        handleTask($task[1]);
    }
}

function handleTask($data) {
    // 处理具体任务逻辑
    echo "处理任务: " . $data . "\n";
    sleep(2);
}

[program:php_worker]
command=php /path/to/worker.php
numprocs=4
autostart=true
autorestart=true
user=www-data
redirect_stderr=true
stdout_logfile=/var/log/php_worker.log