libevent多线程

2024-06-15 06:32
文章标签 多线程 libevent

本文主要是介绍libevent多线程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

使用libevent编写多线程服务端

一、设计框架:

1)主线程监听连接各种事件,创建多个工作线程处理具体业务

2)收到连接时创建对象管理,并绑定到一个线程

3)主线程监听到一个读事件,将该连接添加到所绑定的线程的处理队列

4)工作线程一次取出队列元素,从bufferevent读取数据,并处理

 

二、、设置bufferevent为多线程安全(也就是每次读写bufferevent都是上锁的)

1)设置多线程支持

#ifdef WIN32

evthread_use_windows_threads();

#else

evthread_use_pthreads();

#endif

 

2)创建bufferevent时加上BEV_OPT_THREADSAFE标志

struct bufferevent *bev = NULL;

bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE | BEV_OPT_THREADSAFE);

 

3)此后使用bufferevent缓存就是线程安全的

当然在自己的代码中也可以使用bufferevent的锁

bufferevent_lock(bev);

/*............中间这部分已经加锁...........*/

bufferevent_unlock(bev);  

 

 

三、使用智能指针(std::shared_ptr<type> nodeptr(new type))管理连接对象

1)原因:

创建了一个对象来管理一个连接(bufferevent),在多线程中,可能主线程监听到断开连接,这时就会删除该对象,但是,此时可能工作线程中正通过对象对连接的数据进行处理,如果删除了该对象,造成的后果很可能时段错误-程序崩溃。

2)因此:

收到连接时创建一个智能指针指向连接对象,并用容器保存。

收到连接读事件时,将该连接对象的智能指针传到工作线程的处理队列。

线程取出智能指针后,通过该智能指针调用对象接口。

此时,及时主线程从容器中删除了该智能指针,但是线程中正通过同一对象的智能指针调用对象,对象实际上就不会删除,只有等待工作线程处理结束并跳出智能指针的栈范围,连接对象才会实际删除。

 

如果工作线程处理完对象后,需要向连接写数据,那么一定要注意加锁、加判断条件,因为此时可能连接已经断开了。

 

 

这篇关于libevent多线程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1062676

相关文章

Python多线程实现大文件快速下载的代码实现

《Python多线程实现大文件快速下载的代码实现》在互联网时代,文件下载是日常操作之一,尤其是大文件,然而,网络条件不稳定或带宽有限时,下载速度会变得很慢,本文将介绍如何使用Python实现多线程下载... 目录引言一、多线程下载原理二、python实现多线程下载代码说明:三、实战案例四、注意事项五、总结引

Python多线程应用中的卡死问题优化方案指南

《Python多线程应用中的卡死问题优化方案指南》在利用Python语言开发某查询软件时,遇到了点击搜索按钮后软件卡死的问题,本文将简单分析一下出现的原因以及对应的优化方案,希望对大家有所帮助... 目录问题描述优化方案1. 网络请求优化2. 多线程架构优化3. 全局异常处理4. 配置管理优化优化效果1.

Qt中实现多线程导出数据功能的四种方式小结

《Qt中实现多线程导出数据功能的四种方式小结》在以往的项目开发中,在很多地方用到了多线程,本文将记录下在Qt开发中用到的多线程技术实现方法,以导出指定范围的数字到txt文件为例,展示多线程不同的实现方... 目录前言导出文件的示例工具类QThreadQObject的moveToThread方法实现多线程QC

RabbitMQ消费端单线程与多线程案例讲解

《RabbitMQ消费端单线程与多线程案例讲解》文章解析RabbitMQ消费端单线程与多线程处理机制,说明concurrency控制消费者数量,max-concurrency控制最大线程数,prefe... 目录 一、基础概念详细解释:举个例子:✅ 单消费者 + 单线程消费❌ 单消费者 + 多线程消费❌ 多

Javaee多线程之进程和线程之间的区别和联系(最新整理)

《Javaee多线程之进程和线程之间的区别和联系(最新整理)》进程是资源分配单位,线程是调度执行单位,共享资源更高效,创建线程五种方式:继承Thread、Runnable接口、匿名类、lambda,r... 目录进程和线程进程线程进程和线程的区别创建线程的五种写法继承Thread,重写run实现Runnab

使用Python实现可恢复式多线程下载器

《使用Python实现可恢复式多线程下载器》在数字时代,大文件下载已成为日常操作,本文将手把手教你用Python打造专业级下载器,实现断点续传,多线程加速,速度限制等功能,感兴趣的小伙伴可以了解下... 目录一、智能续传:从崩溃边缘抢救进度二、多线程加速:榨干网络带宽三、速度控制:做网络的好邻居四、终端交互

python多线程并发测试过程

《python多线程并发测试过程》:本文主要介绍python多线程并发测试过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、并发与并行?二、同步与异步的概念?三、线程与进程的区别?需求1:多线程执行不同任务需求2:多线程执行相同任务总结一、并发与并行?1、

Python多进程、多线程、协程典型示例解析(最新推荐)

《Python多进程、多线程、协程典型示例解析(最新推荐)》:本文主要介绍Python多进程、多线程、协程典型示例解析(最新推荐),本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定... 目录一、multiprocessing(多进程)1. 模块简介2. 案例详解:并行计算平方和3. 实现逻

Java使用多线程处理未知任务数的方案介绍

《Java使用多线程处理未知任务数的方案介绍》这篇文章主要为大家详细介绍了Java如何使用多线程实现处理未知任务数,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 知道任务个数,你可以定义好线程数规则,生成线程数去跑代码说明:1.虚拟线程池:使用 Executors.newVir

JAVA封装多线程实现的方式及原理

《JAVA封装多线程实现的方式及原理》:本文主要介绍Java中封装多线程的原理和常见方式,通过封装可以简化多线程的使用,提高安全性,并增强代码的可维护性和可扩展性,需要的朋友可以参考下... 目录前言一、封装的目标二、常见的封装方式及原理总结前言在 Java 中,封装多线程的原理主要围绕着将多线程相关的操