刨析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;

/青狐资源网wcqh.cn/ 解锁

$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青狐资源网wcqh.cn] = 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;