swoole-foundation/swoole-pool

generic swoole client pool

1.0.0 2019-05-20 06:57 UTC

Requires

• ext-swoole: ^4.0.0

Requires (Dev)

• eaglewu/swoole-ide-helper: dev-master

MIT

• xialeistudio

• pool
• coroutine
• swoole

README

基于channel的swoole通用协程池

快速开始

1. 安装依赖

   composer require swoole-foundation/swoole-pool

2. 初始化协程池&&使用协程池(需要在协程下运行)

   <?php
   $pool = new GenericPool(10, function () {
           $connection = new MySQL();
           $connection->connect([
               'host' => '127.0.0.1',
               'port' => 3306,
               'user' => 'root',
               'password' => 'root',
               'database' => 'test',
           ]);
           if (!$connection->connected) {
               throw new Exception($connection->connect_error, $connection->errno);
           }
           return $connection;
       });
   
   
   for ($i = 0; $i < 100; $i++) {
       go(function () use ($pool, $i) {
           /** @var MySQL $connection */
           $connection = $pool->acquire();
           defer(function () use ($pool, $connection) {
               $pool->release($connection);
           });
   
           $data = $connection->query('SELECT CONNECTION_ID() AS `id`');
           print_r($data);
       });
   }