feat: channel优化

workbunny · Sep 29, 2024 · af7b805 · af7b805
1 parent 15d7d48
commit af7b805
Show file tree

Hide file tree

Showing 6 changed files with 30 additions and 5 deletions.
diff --git a/src/Utils/Channel/Channel.php b/src/Utils/Channel/Channel.php
@@ -10,16 +10,28 @@
 use Workbunny\WebmanCoroutine\Factory;
 use Workbunny\WebmanCoroutine\Utils\Channel\Handlers\ChannelInterface;
 use Workbunny\WebmanCoroutine\Utils\Channel\Handlers\DefaultChannel;
+use Workbunny\WebmanCoroutine\Utils\Channel\Handlers\SwooleChannel;
+use Workbunny\WebmanCoroutine\Utils\Channel\Handlers\SwowChannel;
 use Workbunny\WebmanCoroutine\Utils\RegisterMethods;
 
 class Channel
 {
     use RegisterMethods;
 
+    /**
+     * @var ChannelInterface
+     */
     protected ChannelInterface $_interface;
 
+    /**
+     * @var string[]
+     */
     protected static array $_handlers = [
-
+        Factory::WORKERMAN_SWOW => SwowChannel::class,
+        Factory::WORKBUNNY_SWOW => SwowChannel::class,
+        Factory::WORKERMAN_SWOOLE => SwooleChannel::class,
+        Factory::WORKBUNNY_SWOOLE => SwooleChannel::class,
+        Factory::RIPPLE_FIBER => DefaultChannel::class,
     ];
 
     /**

diff --git a/src/Utils/Channel/Handlers/ChannelInterface.php b/src/Utils/Channel/Handlers/ChannelInterface.php
@@ -10,6 +10,17 @@
 interface ChannelInterface
 {
 
+    /**
+     * 初始化通道
+     *
+     * @param int $capacity 初始容量
+     */
+    public function __construct(int $capacity = -1);
+
+    /**
+     * 摧毁通道
+     */
+    public function __destruct();
     /**
      * 获取一个数据
      *

diff --git a/src/Utils/Channel/Handlers/DefaultChannel.php b/src/Utils/Channel/Handlers/DefaultChannel.php
@@ -16,12 +16,14 @@ class DefaultChannel implements ChannelInterface
     /** @var int  */
     protected int $_capacity;
 
+    /** @inheritdoc  */
     public function __construct(int $capacity = -1)
     {
         $this->_queue = new \SplQueue();
         $this->_capacity = $capacity;
     }
 
+    /** @inheritdoc  */
     public function __destruct()
     {
         $this->close();

diff --git a/src/Utils/Channel/Handlers/SwooleChannel.php b/src/Utils/Channel/Handlers/SwooleChannel.php
@@ -15,11 +15,13 @@ class SwooleChannel implements ChannelInterface
     /** @var Channel|null  */
     protected ?Channel $_channel;
 
+    /** @inheritdoc  */
     public function __construct(int $capacity = -1)
     {
         $this->_channel = new Channel($capacity);
     }
 
+    /** @inheritdoc  */
     public function __destruct()
     {
         $this->close();

diff --git a/src/Utils/Channel/Handlers/SwowChannel.php b/src/Utils/Channel/Handlers/SwowChannel.php
@@ -15,11 +15,13 @@ class SwowChannel implements ChannelInterface
     /** @var Channel|null  */
     protected ?Channel $_channel;
 
+    /** @inheritdoc  */
     public function __construct(int $capacity = -1)
     {
         $this->_channel = new Channel($capacity);
     }
 
+    /** @inheritdoc  */
     public function __destruct()
     {
         $this->close();

diff --git a/src/Utils/RegisterMethods.php b/src/Utils/RegisterMethods.php
@@ -11,10 +11,6 @@
 
 trait RegisterMethods
 {
-    /**
-     * @var array
-     */
-    protected static array $_handlers = [];
 
     /**
      * 注册