Reader被kill -9后Writer抛出boost::interprocess::bad_alloc问题求助

核心原因 #

Reader被kill -9强制终止后，无法主动清理共享内存队列的消费状态，导致SPSC队列逐渐被写满，Writer尝试分配新节点时触发bad_alloc异常；另外，共享内存中的同步原语（如内部信号量）可能处于异常状态，也会引发分配失败。

具体解决方案 #

1. 使用有界SPSC队列，避免无界内存耗尽 #

将无界队列替换为固定容量的有界队列，队列满时Writer可选择阻塞等待、超时返回或丢弃消息，而非触发内存分配异常。
示例代码：

// 创建容量为100的有界SPSC队列
using Queue = boost::interprocess::spsc_queue<
    std::string,
    boost::interprocess::managed_shared_memory::allocator<std::string>::type,
    boost::interprocess::bounded_fixed_size<100> // 指定固定容量
>;

// Writer写入时使用非阻塞方式处理队列满的情况
bool write_success = queue.try_push(generate_message());
if (!write_success) {
    // 队列已满，执行等待、日志记录或跳过逻辑
    std::this_thread::sleep_for(std::chrono::milliseconds(100));
}

2. 捕获并处理bad_alloc异常 #

在Writer的写入循环中添加异常捕获逻辑，避免程序直接崩溃，同时加入状态检查与恢复：

while (true) {
    try {
        queue.push(generate_message());
    } catch (const boost::interprocess::bad_alloc& e) {
        std::cerr << "队列写入失败：" << e.what() << std::endl;
        // 检测Reader是否存活，若已崩溃则执行清理或退出
        if (!is_reader_alive()) {
            reset_shared_memory_queue();
            break;
        }
        // 短暂等待后重试
        std::this_thread::sleep_for(std::chrono::seconds(1));
    }
}

3. 添加Reader存活检测 #

在共享内存中维护Reader的PID或心跳时间戳，Writer定期验证Reader状态：

• 共享内存存储Reader的PID，Writer通过kill(pid, 0)（仅检查进程是否存在，不发送信号）判断存活状态。
• Reader定期更新共享内存中的心跳时间戳，Writer若发现时间戳超过阈值，判定Reader已崩溃。

示例代码（存活检测）：

bool is_reader_alive(pid_t reader_pid) {
    // kill(0)不发送信号，仅验证进程是否存在
    return kill(reader_pid, 0) == 0;
}

4. 处理同步原语的异常状态 #

若使用信号量或条件变量同步读写，Writer应使用带超时的等待操作，避免无限阻塞；捕获异常后尝试重置同步原语：

// 带超时的信号量等待，超时则判定Reader可能已崩溃
if (!sem.timed_wait(boost::posix_time::seconds(5))) {
    handle_reader_death();
}

5. 主动清理共享内存资源 #

确认Reader崩溃后，Writer主动销毁并重新初始化共享内存队列，避免后续写入失败：

void reset_shared_memory_queue(boost::interprocess::managed_shared_memory& shmem) {
    // 销毁原有队列
    shmem.destroy<Queue>("queue1");
    shmem.destroy<Queue>("queue2");
    // 重新初始化队列
    auto alloc = shmem.get_allocator<std::string>();
    shmem.construct<Queue>("queue1")(alloc);
    shmem.construct<Queue>("queue2")(alloc);
}

内容的提问来源于stack exchange，提问作者Paul