dreamcat/chan_pool

利用swoole的chan建立池子,以供各工作进程复用

v1.0.0 2019-12-04 02:18 UTC

This package is auto-updated.

Last update: 2024-12-04 12:49:07 UTC


README

介绍

利用swoole的chan建立池子,以供各工作进程复用

安装教程

composer require dreamcat/chan_pool

使用说明

示例代码如下

<?php

use DreamCat\ChanPool\Pojo\ChannelPoolConfig;
use DreamCat\ChanPool\Impl\ChannelEntryPool;

/** @var DreamCat\ChanPool\PoolEntryFactory */
$entryFactory; # 这个工厂只要实现相应接口即可
$poolConfig = new ChannelPoolConfig($entryFactory);
# 根据自己的需要配置池子大小,日志记录器和超时时长
$poolConfig->setSize(10);

$pool = new ChannelEntryPool($poolConfig);

# 在需要的时候取出实体
$entry = $pool->get();
# 用完之后将其放回以便后续使用,不放回会导致后续无法使用
$pool->put($entry);