Swoole 개발 기능의 멀티스레딩 및 멀티프로세스 스케줄링 방법 분석

<?php
use SwooleLock;

// 定义共享变量
$sum = 0;
$n = 10;

// 创建互斥锁
$lock = new Lock(Lock::MUTEX);

// 创建多个线程
$threads = [];

// 线程执行的回调函数
function fib($i) {
    global $sum, $lock;
    
    if ($i == 0 || $i == 1) {
        return $i;
    }
    
    $result = fib($i - 1) + fib($i - 2);
    
    // 加锁
    $lock->lock();
    $sum += $result;
    // 解锁
    $lock->unlock();
    
    return $result;
}

// 创建多个线程并执行
for ($i = 0; $i < $n; $i++) {
    $threads[$i] = new Thread('fib', [$i]);
    $threads[$i]->start();
}

// 等待所有线程执行完毕
foreach ($threads as $thread) {
    $thread->join();
}

// 打印结果
echo "斐波那契数列的前{$n}项和为：{$sum}" . PHP_EOL;

<?php
use SwooleProcess;

// 创建多个进程
$processes = [];

// 创建多个进程并执行任务
for ($i = 0; $i < 4; $i++) {
    $processes[$i] = new Process(function (Process $worker) {
        // 进程内执行的任务
        sleep(2); // 模拟耗时操作
        
        echo "子进程{$worker->pid}执行完毕" . PHP_EOL;
    });
    
    $processes[$i]->start();
}

// 等待所有子进程执行完毕
for ($i = 0; $i < 4; $i++) {
    Process::wait();
}

echo "所有子进程执行完毕" . PHP_EOL;