swoole通用协程池的实现

wanghui 发布于2019-07-01 12:48 / 1117人阅读

摘要：之前过行代码实现通用协程池今天看了下相关文档，用也实现了一个，由于没有的，所以实现的有点简单，但是实用性还可以，通过工厂函数实现了通用性。官方的协程池是用只能用在。因为协程池代码层耦合了实例化逻辑。

之前过golang40行代码实现通用协程池

今天看了下swoole相关文档，用PHP也实现了一个，由于swoole没有golang的select，所以实现的有点简单，但是实用性还可以，通过工厂函数实现了通用性。

swoole官方的协程池是用只能用在Redis。因为协程池代码层耦合了Redis实例化逻辑。

class RedisPool
{
    /**
     * @var SwooleCoroutineChannel
     */
    protected $pool;

    /**
     * RedisPool constructor.
     * @param int $size 连接池的尺寸
     */
    function __construct($size = 100)
    {
        $this->pool = new SwooleCoroutineChannel($size);
        for ($i = 0; $i < $size; $i++)
        {
            $redis = new SwooleCoroutineRedis();
            $res = $redis->connect("127.0.0.1", 6379);
            if ($res == false)
            {
                throw new RuntimeException("failed to connect redis server.");
            }
            else
            {
                $this->put($redis);
            }
        }
    }

    function put($redis)
    {
        $this->pool->push($redis);
    }

    function get()
    {
        return $this->pool->pop();
    }
}

利用工厂方法的改造如下：

size = $size;
        $this->factory = $factory;
        $this->init();
    }


    /**
     * check pool config
     * @throws InvalidParamException
     */
    private function init()
    {
        if ($this->size <= 0) {
            throw new InvalidParamException("The "size" property must be greater than zero.");
        }
        if (empty($this->factory)) {
            throw new InvalidParamException("The "factory" property must be set.");
        }
        if (!is_callable($this->factory)) {
            throw new InvalidParamException("The "factory" property must be callable.");
        }
        $this->bootstrap();
    }

    /**
     * bootstrap pool
     */
    private function bootstrap()
    {
        $this->channel = new Channel($this->size);

        for ($i = 0; $i < $this->size; $i++) {
            $this->channel->push(call_user_func($this->factory));
        }
    }

    /**
     * Acquire a connection
     * @param int $timeout
     * @return mixed
     */
    public function acquire($timeout = 0)
    {
        return $this->channel->pop($timeout);
    }

    /**
     * Release a resource
     * @param mixed $resource
     */
    public function release($resource)
    {
        $this->channel->push($resource);
    }
}

我们代码里面不关心创建连接的具体逻辑，只要调用工厂方法即可。

项目地址

项目已经开源到githubhttps://github.com/swoole-foundation/swoole-pool

GPU云服务器云服务器 python协程池服务器连接池的实现协程 python协程

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/31517.html

Mix PHP V2 实例：AliCloud 短信协程池异步发送守护程序

摘要：前些时间我们发布了实例协程池异步邮件发送守护程序范例，这一次我们提供一个使用大厂通过协程化来并行执行短信发送任务，本文是一个代码简单性能极强的范例。前些时间我们发布了 Mix PHP V2 实例：协程池异步邮件发送守护程序范例，这一次我们提供一个使用大厂 SDK 通过 Swoole Hook 协程化来并行执行短信发送任务，本文是一个代码简单、IO 性能极强的范例。请先升级到 m...

qc1iu 2019-07-01 12:49 评论0 收藏0
Mix PHP V2 实例：协程池异步邮件发送守护程序

摘要：消费者开发使用本例时，请确保你使用的编译时开启了本例我们采用的守护程序协程池来完成一个超高性能的邮件发送程序。去年 Mix PHP V1 发布时，我写了一个多进程的邮件发送实例: 使用 mixphp 打造多进程异步邮件发送，今年 Mix PHP V2 发布，全面的协程支持让我们可以使用一个进程就可达到之前多个进程都无法达到的更高 IO 性能，所以今天重写一个协程池版本的邮件发送实例。...

lauren_liuling 2019-07-01 12:41 评论0 收藏0
Mix PHP V2 新特性：协程、定时器

摘要：主函数查询数据不手动释放的连接不会归还连接池，会在析构时丢弃执行结果为，说明是并行执行的。主函数查询数据即便抛出了异常，仍然能执行到，没有导致内的一直处于阻塞状态。主函数一次性定时持续定时停止定时协程 Mix PHP V2 基于 Swoole 4 的 PHP Stream Hook 协程技术开发，协程使用方式与 Golang 几乎一致，包括框架封装的协程池、连接池、命令行处理都大量参...

Nosee 2019-07-01 12:39 评论0 收藏0