如何取消 hiredis 阻塞操作
How to cancel hiredis blocking operation
像下面这样运行阻塞订阅会在redisGetReply
处停止程序(来源:hiredis#pipelining(
void subscribe (std::string& key, Subscriber* subscriber)
{
void* reply = redisCommand (redis, "SUBSCRIBE %s", key.c_str ());
freeReplyObject (reply);
while (redisGetReply (redis, &reply) == REDIS_OK)
{
subscriber -> notify ();
freeReplyObject (reply);
}
}
我认为通过调用redisFree
(通过信号处理(套接字将被关闭并返回redisGetReply
,如 hiredis#clean-up 中所述,相反,它会引发内存访问违规。
好的,没关系。我设法通过调用来简单地关闭 hiredis 正在使用的文件描述符......
close (redis -> fd);
。并且redisGetReply
正确返回。
或者,可以发送一个QUIT
命令,阻止订阅返回。
相关文章:
- 为什么在popback()操作之后,它仍然打印完整的矢量
- 重载操作程序时出错>>用于类中的字符串 memebr
- 对字符串进行位操作
- 我可以在 C++ 中的函数体之外进行操作吗?
- MPI突然停止了对多个核心的操作
- 如何在信号处理程序和普通函数中对全局变量进行互斥读写操作
- 对字符数组中的元素执行逐位操作
- 如何在directx/c++中进行平移/缩放操作
- 逐位操作的隐式类型转换
- 为什么一个向量上的多线程操作很慢
- 排序时无法执行交换操作.我做的时候它会崩溃.为什么
- 位移操作和位掩码未检测到重复字符
- 如何进行特定的位操作?
- 当我们进行一些操作时,应该使用什么'std::string'或'std::stringstream'?
- 字符串操作 - 字符计数
- 此代码中的操作流程是什么?C/C++.
- 复制和交换习惯用法与移动操作之间的交互
- 像union_这样的 Boost.Geometry 操作如何处理浮点类型的基本不精确性?
- 为什么 std::lerp 不适用于任何已实现所需操作的类型?
- 如何取消 hiredis 阻塞操作