首页 > 其他分享 >【TinyWebServer】03 半同步半反应堆线程池(下)

【TinyWebServer】03 半同步半反应堆线程池(下)

时间:2023-09-08 13:22:20浏览次数:41  
标签:03 函数 静态 成员 TinyWebServer 队列 int 线程

基础知识

静态成员变量

将类成员变量声明为static,则为静态成员变量,与一般的成员变量不同,无论建立多少对象,都只有一个静态成员变量的拷贝,静态成员变量属于一个类,所有对象共享。

静态变量在编译阶段就分配了空间,对象还没创建时就已经分配了空间,放到了全局静态区。

  • 静态成员变量
    • 最好是类内声明,类外初始化(以免类名访问静态成员访问不到)
    • 无论共有,私有,静态成员都可以在类外定义,但私有成员仍有访问权限。
    • 非静态成员类外不能初始化
    • 静态成员数据是共享的

静态成员函数

将类成员函数声明为static,则为静态成员函数。

  • 静态成员函数
    • 静态成员函数可以直接访问静态成员变量,不能直接访问普通成员变量,但可以通过参数传递的方式访问。
    • 普通成员函数可以访问普通成员变量,也可以访问静态成员变量
    • 静态成员函数没有this指针。非静态数据成员为对象单独维护,但静态成员函数为共享函数,无法区分是哪个对象,因此不能直接访问普通变量成员,也没有this指针。

pthread_create陷阱

首先看一下此函数的函数原型:

#include <pthread.h>

int pthread_create (pthread_t *thread_tid,             //返回新生成的线程的id
                   const pthread_attr_t *attr,         //指向线程属性的指针,通常设置为NULL
                   void * (*start_routine) (void *),   //处理线程函数的地址
                   void *arg);                         //start_routine()中的参数

函数原型中的第三个参数的类型为函数指针,指向处理线程函数的地址。该函数要求为静态函数。如果处理线程函数为类成员函数时,需要将其设置为静态成员函数。

this指针的问题

pthread_create的函数原型中第三个参数的类型为函数指针,指向的线程处理函数参数类型为(void *),若线程函数为类成员函数,则this指针会作为默认的参数被传进函数中,从而和线程函数参数(void *)不能匹配,不能通过编译。

静态成员函数就没有这样的问题,里面没有this指针。

线程池分析

线程池的设计模式为半同步/半反应堆,其中反应堆具体为Proactor事件处理模式。

具体的,主线程为异步线程,负责监听文件描述符,接受socket新连接,若当前监听的socket发生了读写事件,然后将任务插入到请求队列。工作线程从请求队列中取出任务,完成读写数据的处理。

线程池类定义

具体定义可以看代码,需要注意,线程处理函数运行函数设置为私有属性。

template <typename T>
class threadpool
{
public:
    /*thread_number是线程池中线程的数量,max_requests是请求队列中最多允许的、等待处理的请求的数量*/
    threadpool(int actor_model, connection_pool *connPool, int thread_number = 8, int max_request = 10000);
    ~threadpool();

    // 向请求队列插入任务请求(reactor模型)
    bool append(T *request, int state);
    // 向请求队列插入任务请求(proactor模型)
    bool append_p(T *request);

private:
    /*工作线程运行的函数,它不断从工作队列中取出任务并执行之*/
    static void *worker(void *arg);
    void run();

private:
    int m_thread_number;        //线程池中的线程数
    int m_max_requests;         //请求队列中允许的最大请求数
    pthread_t *m_threads;       //描述线程池的数组,其大小为m_thread_number
    std::list<T *> m_workqueue; //请求队列
    locker m_queuelocker;       //保护请求队列的互斥锁
    sem m_queuestat;            //是否有任务需要处理
    connection_pool *m_connPool;  //数据库
    int m_actor_model;          //模型切换
};

线程池创建与回收

构造函数中创建线程池,pthread_create函数中将类的对象作为参数传递给静态函数(worker),在静态函数中引用这个对象,并调用其动态方法(run)。

具体的,类对象传递时用this指针,传递给静态函数后,将其转换为线程池类,并调用私有成员函数run。



template <typename T>
threadpool<T>::threadpool( int actor_model, connection_pool *connPool, int thread_number, int max_requests) : m_actor_model(actor_model),m_thread_number(thread_number), m_max_requests(max_requests), m_threads(NULL),m_connPool(connPool)
{
    if (thread_number <= 0 || max_requests <= 0)
        throw std::exception();

    // 线程id初始化
    m_threads = new pthread_t[m_thread_number];
    if (!m_threads)
        throw std::exception();
   
    for (int i = 0; i < thread_number; ++i)
    {
        // 循环创建线程,并将工作线程按要求运行
        if (pthread_create(m_threads + i, NULL, worker, this) != 0)
        {
            delete[] m_threads;
            throw std::exception();
        }

	// 将线程进行分离后,不用单独对工作线程进行回收
        if (pthread_detach(m_threads[i]))
        {
            delete[] m_threads;
            throw std::exception();
        }
    }
}

向请求队列中添加任务

通过list容器创建请求队列,向队列中添加时,通过互斥锁保证线程安全,添加完成后通过信号量提醒有任务要处理,最后注意线程同步。

template <typename T>
bool threadpool<T>::append(T *request, int state)
{
     m_queuelocker.lock();

    // 根据硬件,预先设置请求队列的最大值
    if (m_workqueue.size() >= m_max_requests)
    {
        m_queuelocker.unlock();
        return false;
    }
    request->m_state = state;   // read = 0,write = 1
    // 添加任务
    m_workqueue.push_back(request);
    m_queuelocker.unlock();

    // 信号量提醒有任务要处理
    m_queuestat.post();

    return true;
}

线程处理函数

内部访问私有函数run,完成线程处理要求。

template <typename T>
void *threadpool<T>::worker(void *arg)
{
    // 将参数强转为线程池类,调用成员方法
    threadpool *pool = (threadpool *)arg;
    pool->run();
    return pool;
}

run执行任务

主要实现,工作线程从请求队列中取出某个任务进行处理,注意线程同步

template<typename T>
void threadpool<T>::run()
{
    while(!m_stop)
    {  
        //信号量等待
        m_queuestat.wait();

        //被唤醒后先加互斥锁
        m_queuelocker.lock();
        if(m_workqueue.empty())
        {
            m_queuelocker.unlock();
            continue;
        }

        //从请求队列中取出第一个任务
        T* request=m_workqueue.front();
        //将任务从请求队列删除
        m_workqueue.pop_front();
        m_queuelocker.unlock();
        if(!request)
            continue;

        //从连接池中取出一个数据库连接
        request->mysql = m_connPool->GetConnection();

        //process(模板类中的方法,这里是http类)进行处理
        request->process();

        //将数据库连接放回连接池
        m_connPool->ReleaseConnection(request->mysql);
    }
}











转载文章:

https://mp.weixin.qq.com/s?__biz=MzAxNzU2MzcwMw==&mid=2649274278&idx=5&sn=87470bb3ade0150bb94fcbf33c43c2f8&chksm=83ffbefeb48837e843cfc8258248a1e1b69b48ed993c51861ec63e3b0541fa4714a3846adf90&cur_album_id=1339230165934882817&scene=189#wechat_redirect

标签:03,函数,静态,成员,TinyWebServer,队列,int,线程
From: https://www.cnblogs.com/Wangzx000/p/17686305.html

相关文章

  • 线程安全的队列:使用Monitor模式和C++11多线程库
    线程安全的队列:使用Monitor模式和C++11多线程库引言在多线程编程中,数据共享是一个关键的问题。如果多个线程需要访问同一个数据结构,不正确的管理会导致数据不一致甚至程序崩溃。本文将介绍如何使用C++11的多线程库和Monitor模式来实现一个线程安全的队列。Monitor模式Monitor模式......
  • 线程池拒接测试添加日志
    /***当线程池耗尽时,由调用者负责执行任务,并打印相关日志*/@Slf4jpublicclassCallerRunsWithLogPolicyimplementsRejectedExecutionHandler{publicvoidrejectedExecution(Runnabler,ThreadPoolExecutore){//shutdown():不会立即终止线程池,而是要......
  • CF1103C 题解
    2023-09-0514:52:07solution找路径很好找,我们随便跑个dfs树找个深度\(\ge\frac{n}{k}\)的路径输出即可。可是怎么找\(k\)个长度不是\(3\)的倍数的环呢?既然我们跑了dfs树,那么就没有横叉边,对于叶子节点非树边只有返祖边,然后一看这个很奇怪的条件——保证每个点度数大......
  • UVA10368 题解
    2023-08-0615:18:08solution双倍经验这种有限轮游戏的博弈通常都是有两种状态,必胜态和必败态。对于必胜态,指的是从它可以转移到必败态。对于必败态,指的是从它不论如何只能转移到必胜态。对于每个玩家都采取最优策略的有限游戏,我们通常只需要关注必胜态与必败态之间的转移即......
  • Apktool编译时报error: No resource identifier found for attribute XXX in package
    问题描述使用apktool编译android源码时,报W:XXX.xml:X:error:Noresourceidentifierfoundforattribute'iconTint'inpackage'android'错误。解决方案这是由于API版本较低。处理方法:找到相应文件,把对应的属性删除掉,再重新编译。......
  • 谈谈JSF业务线程池的大小配置
    1.简介JSF业务线程池使用JDK的线程池技术,缺省情况下采用Cached模式(核心线程数20,最大线程数200)。此外,还提供了Fixed固定线程大小的模式,两种模式均可设置请求队列大小。本文旨在通过一个简化场景(“单服务应用”)下的负载测试,为“JSF业务线程池大小配置”提供基准测试结果,并形成一些......
  • P6037 Ryoku 的探索
    题目传送门思路提供首先,我们从题目中可以看到,存在$n$个点$n$条边,所以此题考查的是基环树,那么什么是基环树——基环树是一个$n$个点$n$条边的图,比树多出现一个环。因此,这棵树上是存在一个环的(而且很重要),所以我们要先找出这个环,基环树找环有两种基本的算法,一种是DFS而......
  • CF1829H Don't Blame Me
    比赛链接题解知识点:线性dp,位运算。考虑设\(f_{i,j}\)表示考虑了前\(i\)个数字,与和为\(j\)的方案数。转移方程显然。注意初值为\(f_{0,63}=1\)表示空集,此时注意\(k=6\)时要减去空集这一个方案。当然也可以选择不加入空集,但dp过程需要特别处理只选自己的方案。......
  • 703
    classKthLargest{PriorityQueue<Integer>pq;intk;publicKthLargest(intk,int[]nums){this.k=k;pq=newPriorityQueue<Integer>();for(intx:nums){add(x);}}p......
  • 解决error: no matching member for call to 'connect'
    在连接信号与槽时,报错解决error:nomatchingmemberforcallto'connect'原因由于信号被重载过,同名了,但是参数不一样,就会报错。这种情况下使用使用旧版语法connect(sender,SIGNAL(func()),receiver,SLOT(func1()))......