#ifndef MUTEX_HPP
#define MUTEX_HPP

#include
#include

// 互斥锁封装类：提供加锁/解锁及获取原始锁的接口
class Mutex
{
public:
    // 构造函数：初始化互斥锁
    Mutex()
    {
        pthread_mutex_init(&_lock, nullptr);
    }
    // 析构函数：销毁互斥锁
    ~Mutex()
    {
        pthread_mutex_destroy(&_lock);
    }
    // 加锁操作
    void Lock()
    {
        pthread_mutex_lock(&_lock);
    }
    // 解锁操作
    void UnLock()
    {
        pthread_mutex_unlock(&_lock);
    }
    // 获取原始互斥锁指针，用于需要原生 pthread_mutex_t 的接口
    pthread_mutex_t* Origin()
    {
        return &_lock;
    }
private:
    pthread_mutex_t _lock;  // POSIX 互斥锁
};

// RAII 风格的锁守卫类：构造时加锁，析构时解锁，自动管理锁的生命周期
class LockGuard
{
public:
    // 构造函数：接收一个 Mutex 指针，并立即加锁
    LockGuard(Mutex* lockptr) : _lockptr(lockptr)
    {
        _lockptr->Lock();
    }
    // 析构函数：自动解锁
    ~LockGuard()
    {
        _lockptr->UnLock();
    }
private:
    Mutex* _lockptr;  // 指向被管理的互斥锁
};

#endif

源码核心解读：

接口极简设计：封装了原生pthread_mutex的核心操作，同时给出Origin()接口，方便与条件变量等原生 C 接口配合使用。
RAII 机制保障：LockGuard在对象构造时自动加锁，生命周期结束时自动解锁，无论函数正常返回、异常抛出，都能保证锁被释放，彻底避免锁泄漏。
使用场景：所有临界资源的访问（如线程池任务队列、日志文件写入）都通过LockGuard保护，无需手动调用unlock，代码更健壮。

2.2 条件变量封装（Cond.hpp）

条件变量用于线程间的通知机制，配合互斥锁实现生产者 - 消费者模型，是线程池的核心同步组件。

#ifndef COND_HPP
#define COND_HPP

#include
#include

#include "Mutex.hpp"

/**
 * @brief 条件变量封装类
 * 核心逻辑：提供线程间的通知机制。
 * 它允许线程在某些条件不满足时挂起，并在其他线程改变条件并发送信号时被唤醒。
 */
class Cond
{
public:
    // 构造函数：初始化条件变量
    Cond()
    {
        // nullptr 表示使用操作系统默认的条件变量属性
        pthread_cond_init(&cond, nullptr);
    }

    /**
     * @brief 等待条件满足
     * @param mutex 必须是当前线程已经持有的互斥锁
     * * 底层逻辑“三步跳”：
     * 1. 自动释放传入的 mutex 锁（这样其他线程才能修改临界资源）。
     * 2. 将当前线程挂起并加入到该条件变量的等待队列中。
     * 3. 当被唤醒返回时，会自动尝试重新竞争并持有该 mutex 锁。
     */
    void Wait(Mutex &mutex)
    {
        // 调用封装好的 Mutex 类的 Origin() 接口，配合底层 C 接口使用
        pthread_cond_wait(&cond, mutex.Origin());
    }

    // 唤醒一个在此条件变量下等待的线程
    void NotifyOne()
    {
        // 唤醒队列中的第一个线程（如果存在）
        pthread_cond_signal(&cond);
    }

    // 唤醒所有在此条件变量下等待的线程
    void NotifyAll()
    {
        // 广播通知，常用于多个消费者或复杂的资源变动场景
        pthread_cond_broadcast(&cond);
    }

    // 析构函数：销毁条件变量资源
    ~Cond()
    {
        /**
         * 注意事项：
         * 销毁一个仍有线程在等待的条件变量是危险行为。
         * 在线程池销毁前，通常需要先调用 NotifyAll 并回收所有线程。
         */
        pthread_cond_destroy(&cond);
    }

private:
    pthread_cond_t cond; // POSIX 线程库提供的底层条件变量结构
};

#endif

源码核心解读：

Wait 函数的底层 “三步跳”：这是条件变量最核心的考点

自动释放传入的互斥锁，让其他线程能够修改临界资源

将当前线程挂起，加入条件变量的等待队列
被唤醒返回时，自动重新竞争并持有互斥锁

唤醒机制区分：NotifyOne用于常规任务通知，NotifyAll用于线程池优雅退出等需要唤醒所有线程的场景。
使用规范：条件变量的等待一定要配合while循环（而非 if），避免虚假唤醒，这一点在线程池实现中会重点体现。

2.3 线程封装（Thread.hpp）

对原生 POSIX 线程库进行 C++ 封装，解决了类成员函数作为线程入口的参数匹配麻烦，同时给出了线程命名、LWP 获取、状态管理等实用能力。

```

ifndef __THREAD_HPP

define __THREAD_HPP

include

// 定义线程执行的任务类型，使用包装器增强灵活性
using func_t = std::function;

// 线程状态枚举：用于构建简单的状态机，确保护法操作
enum class TSTAYUS
{
THREAD_NEW, // 新建状态
THREAD_RUNNING, // 运行状态
THREAD_STOPPED, // 停止/退出状态
};

// 这个是有点bug的：全局静态变量在多线程并发创建对象时存在“竞态条件”
// 多个线程可能同时执行 gunm++，导致线程编号重复，生产环境下建议使用 std::atomic
static int gunm = 1;

class Thread
{
private:
// 获取所属进程的 PID
void get_pid()
{
_pid = getpid();
}
// 获取内核级线程 ID (LWP ID)，这才是 Linux 系统监控（如 top -H）看到的真正 ID
void get_lwid()
{
// 原生 pthread 库没有直接获取 LWP 的接口，一定要通过系统调用
_lwid = syscall(SYS_gettid);
}

/**
@brief 静态成员函数作为线程入口点
关键逻辑：pthread_create 要求回调函数一定要是 void ()(void)
类的普通成员函数隐含 this 指针，参数不匹配，故必须设为 static。
通过传入 args (this 指针) 重新找回对象上下文。
/
static void routine(void args)
{
Thread* ts = static_cast(args);
ts->get_pid();
ts->get_lwid();

// 为线程设置名字，方便在调试器（如 gdb）中识别
pthread_setname_np(pthread_self(), ts->Name().c_str());

// 执行用户真正传入的任务
ts->_func();
return nullptr;
}

public:
// 构造函数：做好任务绑定与命名，此时线程尚未在内核中创建
Thread(func_t f) : _func(f), _joinable(true), _status(TSTAYUS::THREAD_NEW)
{
_name = "Worker-" + std::to_string(gunm++);
}

// 启动线程：正式调用底层接口
void start()
{
if(_status == TSTAYUS::THREAD_RUNNING)
{
std::cerr

今天的内容大概就这些，实际开发中大家还会遇到更多细节，欢迎留言分享自己的经验。

小丸子博客

分享：【Linux网络】高性能 TCP 服务器：从多线程到线程池的架构演进与落地实践

前言

一. TCP 服务器核心模型演进

二. 自研基础组件深度解析

2.1 互斥锁与 RAII 锁守卫（Mutex.hpp）

2.2 条件变量封装（Cond.hpp）

2.3 线程封装（Thread.hpp）

ifndef __THREAD_HPP

define __THREAD_HPP

include

include

include

include

include

include

include

评论 (0)