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

相关文章

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

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

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

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

Python中多线程和多进程的基本用法详解

《Python中多线程和多进程的基本用法详解》这篇文章介绍了Python中多线程和多进程的相关知识,包括并发编程的优势,多线程和多进程的概念、适用场景、示例代码,线程池和进程池的使用,以及如何选择合适... 目录引言一、并发编程的主要优势二、python的多线程(Threading)1. 什么是多线程?2.

SpringBoot中使用 ThreadLocal 进行多线程上下文管理及注意事项小结

《SpringBoot中使用ThreadLocal进行多线程上下文管理及注意事项小结》本文详细介绍了ThreadLocal的原理、使用场景和示例代码,并在SpringBoot中使用ThreadLo... 目录前言技术积累1.什么是 ThreadLocal2. ThreadLocal 的原理2.1 线程隔离2

Java多线程父线程向子线程传值问题及解决

《Java多线程父线程向子线程传值问题及解决》文章总结了5种解决父子之间数据传递困扰的解决方案,包括ThreadLocal+TaskDecorator、UserUtils、CustomTaskDeco... 目录1 背景2 ThreadLocal+TaskDecorator3 RequestContextH

C#多线程编程中导致死锁的常见陷阱和避免方法

《C#多线程编程中导致死锁的常见陷阱和避免方法》在C#多线程编程中,死锁(Deadlock)是一种常见的、令人头疼的错误,死锁通常发生在多个线程试图获取多个资源的锁时,导致相互等待对方释放资源,最终形... 目录引言1. 什么是死锁?死锁的典型条件:2. 导致死锁的常见原因2.1 锁的顺序问题错误示例:不同

浅析Rust多线程中如何安全的使用变量

《浅析Rust多线程中如何安全的使用变量》这篇文章主要为大家详细介绍了Rust如何在线程的闭包中安全的使用变量,包括共享变量和修改变量,文中的示例代码讲解详细,有需要的小伙伴可以参考下... 目录1. 向线程传递变量2. 多线程共享变量引用3. 多线程中修改变量4. 总结在Rust语言中,一个既引人入胜又可

多线程解析报表

假如有这样一个需求,当我们需要解析一个Excel里多个sheet的数据时,可以考虑使用多线程,每个线程解析一个sheet里的数据,等到所有的sheet都解析完之后,程序需要提示解析完成。 Way1 join import java.time.LocalTime;public class Main {public static void main(String[] args) thro

Java 多线程概述

多线程技术概述   1.线程与进程 进程:内存中运行的应用程序,每个进程都拥有一个独立的内存空间。线程:是进程中的一个执行路径,共享一个内存空间,线程之间可以自由切换、并发执行,一个进程最少有一个线程,线程实际数是在进程基础之上的进一步划分,一个进程启动之后,进程之中的若干执行路径又可以划分成若干个线程 2.线程的调度 分时调度:所有线程轮流使用CPU的使用权,平均分配时间抢占式调度

Java 多线程的基本方式

Java 多线程的基本方式 基础实现两种方式: 通过实现Callable 接口方式(可得到返回值):