Added Barrier (#36)

Author: huangdijia

composer.json

@@ -24,7 +24,7 @@
     },
     "require": {
         "php": ">=8.0",
-        "hyperf/engine-contract": "~1.12.0"
+        "hyperf/engine-contract": "~1.13.0"
     },
     "require-dev": {
         "friendsofphp/php-cs-fixer": "^3.0",
@@ -52,7 +52,7 @@
     },
     "extra": {
         "branch-alias": {
-            "dev-master": "2.13-dev"
+            "dev-master": "2.14-dev"
         },
         "hyperf": {
             "config": "Hyperf\\Engine\\ConfigProvider"

src/Barrier.php

@@ -0,0 +1,29 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * This file is part of Hyperf.
+ *
+ * @link     https://www.hyperf.io
+ * @document https://hyperf.wiki
+ * @contact  group@hyperf.io
+ * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
+ */
+
+namespace Hyperf\Engine;
+
+use Hyperf\Engine\Contract\BarrierInterface;
+use Swoole\Coroutine\Barrier as SwooleBarrier;
+
+class Barrier implements BarrierInterface
+{
+    public static function wait(object &$barrier, int $timeout = -1): void
+    {
+        SwooleBarrier::wait($barrier, $timeout);
+    }
+
+    public static function create(): object
+    {
+        return SwooleBarrier::make();
+    }
+}

tests/Cases/BarrierTest.php

@@ -0,0 +1,41 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * This file is part of Hyperf.
+ *
+ * @link     https://www.hyperf.io
+ * @document https://hyperf.wiki
+ * @contact  group@hyperf.io
+ * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
+ */
+
+namespace HyperfTest\Cases;
+
+use Hyperf\Engine\Barrier;
+use Hyperf\Engine\Coroutine;
+
+/**
+ * @internal
+ * @coversNothing
+ */
+class BarrierTest extends AbstractTestCase
+{
+    public function testBarrier()
+    {
+        $this->runInCoroutine(function () {
+            $barrier = Barrier::create();
+            $N = 10;
+            $count = 0;
+            for ($i = 0; $i < $N; ++$i) {
+                Coroutine::create(function () use (&$count, $barrier) {
+                    isset($barrier);
+                    usleep(2000);
+                    ++$count;
+                });
+            }
+            Barrier::wait($barrier);
+            $this->assertSame($N, $count);
+        });
+    }
+}