【15】介绍下你的项目(之前答的很差,明明总结过两遍,还细细研究过,一个多月不看又忘的七七八八了,这里重新整理下): 1) 首先,最外层是线程池,是半同步/半反应堆线程池,这里的半同步/半反应堆的具体工作流程是,以 Proactor 为例: 主线程充当异步线程,如果 socket 上有事件发生,主线程读取后将数据封装成请求对象插入请求队列,然后请求队列上的工作线程,通过竞争获得任务接管权 这里通过一个工作队列,解除了主线程和工作线程的耦合关系 具体实现呢,有 5 部分,类定义,线程池的创建和回收,向请求队列添加任务,线程处理函数 work() 和 执行任务函数 run() 5 部分结合起来,就是常考的手撕线程池 2) 第二个呢,就是日志系统,项目中的日志系统是异步实现的,为什么不用同步呢,因为同步时,写入函数和工作线程是 串行的,当单条日志比较大,或者峰值的时候,写日志就会成为性能瓶颈。 而异步会将日志内容先存入阻塞队列,写线程先从阻塞队列取出内容,再写入,就可以避免阻塞。这里实际就是并发编程中经典的生产者/消费者模型,生产者线程和消费者线程共享同一个缓冲区,缓冲区底层是循环数组实现的阻塞队列。 3) 第三个就是定时器模块,可以定期检测非活跃连接,及时释放连接资源。 项目中,具体就是,服务器为每个连接创建一个定时器,定时器放在升序链表中,按超时时间升序排列,到期的定时器会从链表中删除,这里插入定时器的时间复杂度是O(n),删除的复杂度是O(1) 4) 第四个,http 连接的处理,也是本项目最复杂的一部分,整个项目约3000行代码,其中 http 的 .h 和 .cpp 两个文件,就占了800行 分 3 部分请求报文的读取,接收和响应 请求报文接收,涉及到对 http 报文格式和状态码的处理 解析部分,主要是主从状态机这个抽象模型 通过从状态机读取一行,然后由主状态机解析,分别对请求行,请求头和请求内容进行处理,其中解析请求头包含对GET的解析,解析请求内容,包含对POST的解析 响应部分,调用了sys/stat等多个头文件 5) 最后就是数据库连接池,类似前面提到的线程池,本质都是空间换时间,对资源的复用 项目中,使用局部静态变量的懒汉模式,来创建连接池 连接池的释放,通过 RAII 机制封装,避免了手动释放
点赞 1

相关推荐

牛客网
牛客企业服务