ตัวกั้นร่วมข้อ Barrier

Barrier เป็นเครื่องมือสำหรับการซิงโครไนซ์ของการทำงานร่วมกัน ซึ่งอนุญาตให้รอให้การทำงานร่วมกันทั้งหมดเสร็จสิ้นก่อนที่จะดำเนินการต่อในลอจิกถัดไป Barrier ถูกสร้างขึ้นบนพื้นฐานการนับจำนวนอ้างอิงของ PHP

หมายเหตุ
ระบบจะตรวจจับประเภทไดรเวอร์โดยอัตโนมัติ สนับสนุนเฉพาะ Swoole/Swow/Fiber เท่านั้น

เคล็ดลับ
ฟีเจอร์นี้ต้องการ workerman>=5.1.0

<?php
use Workerman\Connection\TcpConnection;
use Workerman\Coroutine\Barrier;
use Workerman\Coroutine;
use Workerman\Events\Swoole;
use Workerman\Protocols\Http\Request;
use Workerman\Worker;
require_once __DIR__ . '/vendor/autoload.php';

// Http Server
$worker = new Worker('http://0.0.0.0:8001');
$worker->eventLoop = Swoole::class; // หรือ Swow::class หรือ Fiber::class
$worker->onMessage = function (TcpConnection $connection, Request $request) {
    $barrier = Barrier::create();
    for ($i=1; $i<5; $i++) {
        Coroutine::create(function () use ($barrier, $i) {
            // ทำบางอย่าง
        });
    }
    // รอให้การทำงานร่วมกันทั้งหมดเสร็จสิ้น
    Barrier::wait($barrier);
    $connection->send('งานทั้งหมดเสร็จสิ้น');
};

Worker::runAll();

คำอธิบาย API

interface BarrierInterface
{
    /**
     * สร้างอ็อบเจ็กต์ Barrier ใหม่
     */
    public static function create(): object;

    /**
     * หยุดชั่วคราวการทำงานร่วมกันในปัจจุบัน รอให้การทำงานทั้งหมดใน Barrier ที่กำหนดเสร็จสิ้น
     */
    public static function wait(object &$barrier, int $timeout = -1): void;
}