#include <beanstalk_pool.hpp>
beanstalk 客户端连接池,可以同时连接不同的 beanstalkd 服务器, 每个 beanstalkd 有多个连接,内部自动加锁;但不控制连接数限制, 用户应自行控制连接池的最大连接上限
在文件 beanstalk_pool.hpp 第 18 行定义.
◆ beanstalk_pool()
acl::beanstalk_pool::beanstalk_pool |
( |
| ) |
|
◆ ~beanstalk_pool()
acl::beanstalk_pool::~beanstalk_pool |
( |
| ) |
|
◆ peek()
beanstalk* acl::beanstalk_pool::peek |
( |
const char * |
addr, |
|
|
bool |
clean_watch = true , |
|
|
int |
conn_timeout = 60 |
|
) |
| |
从连接池中取得一个 beanstalkd 的客户端连接
- 参数
-
addr | {const char*} beanstalkd 服务地址(domain:port) |
clean_watch | {bool} 在取得连接对象后是否自动取消所有的 已关注队列 |
conn_timeout | {int} 连接 beanstalkd 的超时时间 |
- 返回
- {beanstalk*} 返回非空表示正常,否则表示出错
◆ put()
void acl::beanstalk_pool::put |
( |
beanstalk * |
client, |
|
|
bool |
clean_watch = true , |
|
|
bool |
keep = true |
|
) |
| |
将不用的 beanstalkd 连接放回到连接池中
- 参数
-
client | {beanstalk*} beanstalkd 客户端连接 |
clean_watch | {bool} 是否取消已经关注的队列 |
keep | {bool} 如果为 true 则将 client 放回至连接池, 否则释放该连接 |
该类的文档由以下文件生成: