快捷導(dǎo)航

C++實(shí)現(xiàn)一個(gè)簡單的線程池的示例代碼

更新時(shí)間：2022年05月19日 08:55:54 作者：phil__naiping

本文主要介紹了C++實(shí)現(xiàn)一個(gè)簡單的線程池的示例代碼，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

一、設(shè)計(jì)

線程池應(yīng)該包括

保存線程的容器，保存任務(wù)的容器。
為了能保證避免線程對(duì)任務(wù)的競態(tài)獲取，需要對(duì)任務(wù)隊(duì)列進(jìn)行加鎖。
為了使得工作線程感知任務(wù)的到來，需要使用條件變量來喚醒工作線程。
任務(wù)容器中的任務(wù)管理。
任務(wù)的處理API。

二、參數(shù)選擇

使用數(shù)組存放線程，鏈表存放任務(wù)。

請(qǐng)?zhí)砑訄D片描述

三、類設(shè)計(jì)

線程池類

template<typename T>
class threadpool
{
public:
    threadpool(int thread_num,int max_request);
    ~threadpool();
    bool append(T* request);    // 在任務(wù)隊(duì)列中添加任務(wù)
private:
    static void worker(void* arg);
    void run();
private:
    int m_thread_num;           // 線程池中的線程數(shù)
    int m_max_request;          // 任務(wù)隊(duì)列最大保存的任務(wù)數(shù)
    pthread_t *m_threads;       // 保存線程的容器
    std::list<T*>m_queuework;   // 保存任務(wù)的鏈表
    sem m_sem;                  // 通知工作線程任務(wù)到來
    lock m_locker;				// 互斥訪問任務(wù)隊(duì)列
};

構(gòu)造函數(shù)

template<typename T>
threadpool<T>::threadpool(int thread_num,int max_request):m_thread_num(thread_num),m_max_request(max_request)
{
    if(thread_num <=0 || max_request <= 0) throw std::exception();
    m_threads = new pthread_t[thread_num];
    if(!m_threads) throw std::exception();
    for(int i = 0;i < thread_num;++i)
    {
        // 創(chuàng)建線程
        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();
        }
    }
}

析構(gòu)函數(shù)

template<typename T>
threadpool<T>::~threadpool()
{
   delete[] m_trheads;
}

添加任務(wù)函數(shù)

template<typename T>
bool threadpool<T>::append(T* request)
{
    m_locker.lock();
    if(m_queuework.size() > m_max_request)
    {
         m_locker.unlock();
         return false;
    } 
    m_queuework.push_back(request);
    m_locker.unlock();
    m_sem.post();
    return true;
}

任務(wù)處理函數(shù)

template<typename T>
void* threadpool<T>::worker(void*arg)
{
    threadpool* pool = (threadpool*)arg;
    pool->run();
    return pool;
}

template<typename T>
void threadpool<T>::run()
{
    while(true)
    {
         m_sem.wait();
         m_locker.lock();
         if(m_queuework.empty())
         {
             m_locker.unlock();
             continue;
         }
         T* request = m_queuework.front();
         m_queuework.pop_front();
         m_locker.unlock();      
         request.process();      // 具體任務(wù)的處理業(yè)務(wù)
    }
}

到此這篇關(guān)于C++實(shí)現(xiàn)一個(gè)簡單的線程池的示例代碼的文章就介紹到這了,更多相關(guān)C++ 線程池內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: