欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

c++實(shí)現(xiàn)簡(jiǎn)單的線(xiàn)程池

 更新時(shí)間:2015年03月24日 17:02:06   投稿:hebedich  
本文介紹的線(xiàn)程池采用C++語(yǔ)言,在windows平臺(tái)下實(shí)現(xiàn)。本著技術(shù)分享的精神寫(xiě)作本文同時(shí)公布源代碼。歡迎大家指出該線(xiàn)程池存在的問(wèn)題并對(duì)當(dāng)前性能進(jìn)行討論。

c++線(xiàn)程池,繼承CDoit,實(shí)現(xiàn)其中的start和end

頭文件

/*
 * 多線(xiàn)程管理類(lèi)
 * 
 */
 
#ifndef CTHREADPOOLMANAGE_H
#define CTHREADPOOLMANAGE_H
#include <iostream>
#include <pthread.h>
#include <unistd.h> 
#include <list>
#include <vector>
#include <time.h>
#include <asm/errno.h>
 
#define USLEEP_TIME 100
#define CHECK_TIME 1
 
 
using namespace std;
class CDoit
{
public:
 virtual int start(void *){};
 virtual int end(){};
};
 
 
class CthreadPoolManage
{
private:
 int _minThreads;  //最少保留幾個(gè)線(xiàn)程
 int _maxThreads;  //最多可以有幾個(gè)線(xiàn)程
 int _waitSec;      //空閑多少秒后將線(xiàn)程關(guān)閉
 class threadInfo{
  public:
  threadInfo(){
   isbusy = false; 
   doFlag = true;
  }
  //
  pthread_mutex_t mtx=PTHREAD_MUTEX_INITIALIZER;
  pthread_cond_t cond=PTHREAD_COND_INITIALIZER;
  bool isbusy;   //是否空閑
  bool doFlag;
  //
  time_t beginTime;     //線(xiàn)程不工作開(kāi)始時(shí)間
  pthread_t cThreadPid; //線(xiàn)程id
  pthread_attr_t cThreadAttr; //線(xiàn)程屬性
  CDoit * doit;         //任務(wù)類(lèi)
  void  * value;        //需要傳遞的值
 };
 //線(xiàn)程函數(shù)
 static void* startThread(void*);
 //任務(wù)隊(duì)列鎖
 pthread_mutex_t _duty_mutex;
 //任務(wù)隊(duì)列
 list<threadInfo*> _dutyList;
 //線(xiàn)程隊(duì)列鎖
 pthread_mutex_t _thread_mutex;
 //線(xiàn)程隊(duì)列
 list<threadInfo*> _threadList;
  
///初始化,創(chuàng)建最小個(gè)數(shù)線(xiàn)程///
void initThread(); 
///任務(wù)分配線(xiàn)程///
static void* taskAllocation(void*arg);
pthread_t tasktPid;
///線(xiàn)程銷(xiāo)毀、狀態(tài)檢查線(xiàn)程///
static void* checkThread(void* arg);
pthread_t checktPid;
bool  checkrun;
 
//線(xiàn)程異常退出清理
static void threadCleanUp(void* arg);
 
//
int addThread(list<threadInfo*> *plist,threadInfo* ptinfo);
 
public:
CthreadPoolManage();
/*
保留的最少線(xiàn)程,最多線(xiàn)程數(shù),空閑多久銷(xiāo)毀,保留幾個(gè)線(xiàn)程的冗余
 */
CthreadPoolManage(int min,int max,int waitSec);
~CthreadPoolManage();
 
int start();
//任務(wù)注入器
int putDuty(CDoit *,void *);
 
int getNowThreadNum();
 
};
 
#endif // CTHREADPOOLMANAGE_H

CPP文件

/*
 * 線(xiàn)程池,線(xiàn)程管理類(lèi)
 * 
 */
 
#include "cthreadpoolmanage.h"
 
CthreadPoolManage::CthreadPoolManage()
{
 _minThreads = 5;  //最少保留幾個(gè)線(xiàn)程
 _maxThreads = 5;  //最多可以有幾個(gè)線(xiàn)程
 _waitSec = 10;      //空閑多少秒后將線(xiàn)程關(guān)閉
 pthread_mutex_init(&_duty_mutex, NULL);
 pthread_mutex_init(&_thread_mutex, NULL);
 checkrun = true;
}
 
 
CthreadPoolManage::CthreadPoolManage(int min, int max, int waitSec)
{
  CthreadPoolManage();
  _minThreads = min;  //最少保留幾個(gè)線(xiàn)程
  _maxThreads = max;  //最多可以有幾個(gè)線(xiàn)程
  _waitSec = waitSec;      //空閑多少秒后將線(xiàn)程關(guān)閉
}
 
CthreadPoolManage::~CthreadPoolManage()
{
 
}
void CthreadPoolManage::threadCleanUp(void* arg)
{
 threadInfo* tinfo = (threadInfo*)arg;
 tinfo->isbusy = false;
 pthread_mutex_unlock(&tinfo->mtx);
 pthread_attr_destroy (&tinfo->cThreadAttr);
 delete tinfo;
}
 
void* CthreadPoolManage::startThread(void* arg)
{
 cout<<"線(xiàn)程開(kāi)始工作"<<endl;
 threadInfo* tinfo = (threadInfo*)arg;
 pthread_cleanup_push(threadCleanUp,arg);
 while(tinfo->doFlag){
  pthread_mutex_lock(&tinfo->mtx);
  if(tinfo->doit == NULL)
  {
   cout<<"開(kāi)始等待任務(wù)"<<endl;
   pthread_cond_wait(&tinfo->cond,&tinfo->mtx);
   cout<<"有任務(wù)了"<<endl;
  }
  tinfo->isbusy = true;
  tinfo->doit->start(tinfo->value);
  tinfo->doit->end();
  tinfo->doit=NULL;
  tinfo->isbusy = false;
  time( &tinfo->beginTime);
  pthread_mutex_unlock(&tinfo->mtx);
 }
 //0正常執(zhí)行到這兒不執(zhí)行清理函數(shù),異常會(huì)執(zhí)行
 pthread_cleanup_pop(0);
 pthread_attr_destroy (&tinfo->cThreadAttr);
 delete tinfo;
 cout<<"線(xiàn)程結(jié)束"<<endl;
}
 
void CthreadPoolManage::initThread()
{
 int i = 0;
 for(i = 0;i<this->_minThreads;i++)
 {
   threadInfo *tinfo = new threadInfo;
   tinfo->doit = NULL;
   tinfo->value = NULL;
   tinfo->isbusy = false;
   tinfo->doFlag = true;
  // PTHREAD_CREATE_DETACHED (分離線(xiàn)程) 和 PTHREAD _CREATE_JOINABLE (非分離線(xiàn)程)
   pthread_attr_init(&tinfo->cThreadAttr);
   pthread_attr_setdetachstate(&tinfo->cThreadAttr,PTHREAD_CREATE_DETACHED );
   cout<<"初始化了一個(gè)線(xiàn)程"<<endl;
   if(pthread_create(&tinfo->cThreadPid,&tinfo->cThreadAttr,startThread,(void *)tinfo) != 0)
  {
  cout<<"創(chuàng)建線(xiàn)程失敗"<<endl;
  break;
  }
  this->_threadList.push_back(tinfo);
 }
}
 
int CthreadPoolManage::addThread(std::list< CthreadPoolManage::threadInfo* >* plist, CthreadPoolManage::threadInfo* ptinfo)
{
   threadInfo *tinfo = new threadInfo;
   tinfo->doit = ptinfo->doit;
   tinfo->value = ptinfo->value;
   tinfo->isbusy = true;
   if(pthread_create(&tinfo->cThreadPid,NULL,startThread,(void *)tinfo) != 0)
  {
  cout<<"創(chuàng)建線(xiàn)程失敗"<<endl;
  return -1;
  }
  plist->push_back(tinfo);
  return 0;
}
 
 
int CthreadPoolManage::putDuty(CDoit* doit, void* value)
{
 threadInfo *tinfo = new threadInfo;
 time( &tinfo->beginTime);
 tinfo->doit= doit;
 tinfo->value = value;
 pthread_mutex_lock(&_duty_mutex);
  this->_dutyList.push_back(tinfo);
 pthread_mutex_unlock(&_duty_mutex);
 return 0;
}
 
void* CthreadPoolManage::taskAllocation(void*arg)
{
 CthreadPoolManage * ptmanage = (CthreadPoolManage*)arg;
 int size_1 = 0;
 int size_2 = 0;
 int i_1 = 0;
 int i_2 = 0;
 bool a_1 = true;
 bool a_2 = true;
 threadInfo* ptinfo;
 threadInfo* ptinfoTmp;
 while(true){
   size_1 = 0;
   size_2 = 0;
   pthread_mutex_lock(&ptmanage->_duty_mutex);
   pthread_mutex_lock(&ptmanage->_thread_mutex);
   size_1 = ptmanage->_dutyList.size();
   size_2 =ptmanage->_threadList.size();
   for(list<threadInfo*>::iterator itorti1 = ptmanage->_dutyList.begin();itorti1 !=ptmanage->_dutyList.end();)
   {
  ptinfo = *itorti1;
  a_1 = true;
  for(list<threadInfo*>::iterator itorti2 = ptmanage->_threadList.begin();itorti2!=ptmanage->_threadList.end();itorti2++){
   ptinfoTmp = *itorti2;
   if(EBUSY == pthread_mutex_trylock(&ptinfoTmp->mtx))
   {
    continue;
   }
   if(!ptinfoTmp->isbusy)
   {
    ptinfoTmp->doit = ptinfo->doit;
    ptinfoTmp->value = ptinfo->value;
    ptinfoTmp->isbusy = true;
    pthread_cond_signal(&ptinfoTmp->cond);
    pthread_mutex_unlock(&ptinfoTmp->mtx);
    a_1 = false;
    delete ptinfo;
    break;
   }
   pthread_mutex_unlock(&ptinfoTmp->mtx);
    }
    if(a_1){
   if(ptmanage->_threadList.size()>ptmanage->_maxThreads||ptmanage->addThread(&ptmanage->_threadList,ptinfo)!=0)
   {
    itorti1++;
    continue;
   }else{
    itorti1 = ptmanage->_dutyList.erase(itorti1);
   }
   delete ptinfo;
    }else{
   itorti1 = ptmanage->_dutyList.erase(itorti1);
    }
   }
   pthread_mutex_unlock(&ptmanage->_duty_mutex);
   pthread_mutex_unlock(&ptmanage->_thread_mutex);
   usleep(USLEEP_TIME);
 }
 return 0;
}
 
void* CthreadPoolManage::checkThread(void* arg)
{
 CthreadPoolManage * ptmanage = (CthreadPoolManage*)arg;
 threadInfo* ptinfo;
 time_t nowtime;
 while(ptmanage->checkrun){
  sleep(CHECK_TIME);
  pthread_mutex_lock(&ptmanage->_thread_mutex);
  if(ptmanage->_threadList.size()<=ptmanage->_minThreads)
  {
   continue;
  }
  for(list<threadInfo*>::iterator itorti2 = ptmanage->_threadList.begin();itorti2!=ptmanage->_threadList.end();){
   ptinfo = *itorti2;
   if(EBUSY == pthread_mutex_trylock(&ptinfo->mtx))
  {
   itorti2++;
   continue;
  }
  time(&nowtime);
  if(ptinfo->isbusy == false && nowtime-ptinfo->beginTime>ptmanage->_waitSec)
  {
   ptinfo->doFlag = false;
   itorti2 = ptmanage->_threadList.erase(itorti2);
  }else{
   itorti2++;
  }
  pthread_mutex_unlock(&ptinfo->mtx);
  }
  pthread_mutex_unlock(&ptmanage->_thread_mutex);
 }
}
 
int CthreadPoolManage::start()
{
 //初始化
 this->initThread();
 //啟動(dòng)任務(wù)分配線(xiàn)程
  if(pthread_create(&tasktPid,NULL,taskAllocation,(void *)this) != 0)
  {
  cout<<"創(chuàng)建任務(wù)分配線(xiàn)程失敗"<<endl;
  return -1;
  }
  //創(chuàng)建現(xiàn)程狀態(tài)分配管理線(xiàn)程
  if(pthread_create(&checktPid,NULL,checkThread,(void *)this) != 0)
  {
  cout<<"創(chuàng)建線(xiàn)程狀態(tài)分配管理線(xiàn)程失敗"<<endl;
  return -1;
  }
 return 0;
}
 
///////////////////////////////
int CthreadPoolManage::getNowThreadNum()
{
 int num = 0;
 pthread_mutex_lock(&this->_thread_mutex);
  num = this->_threadList.size();
 pthread_mutex_unlock(&this->_thread_mutex);
 return num ;
}

以上所述就是本文的全部?jī)?nèi)容了,希望大家能夠喜歡。

請(qǐng)您花一點(diǎn)時(shí)間將文章分享給您的朋友或者留下評(píng)論。我們將會(huì)由衷感謝您的支持!

相關(guān)文章

  • OpenCV霍夫變換(Hough Transform)直線(xiàn)檢測(cè)詳解

    OpenCV霍夫變換(Hough Transform)直線(xiàn)檢測(cè)詳解

    這篇文章主要為大家詳細(xì)介紹了OpenCV霍夫變換直線(xiàn)檢測(cè)的相關(guān)資料,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2018-12-12
  • C語(yǔ)言中的內(nèi)存管理詳情

    C語(yǔ)言中的內(nèi)存管理詳情

    這篇文章主要介紹了C語(yǔ)言中的內(nèi)存管理詳情,手工申請(qǐng)內(nèi)存使用malloc展開(kāi)全文內(nèi)容,具有一定的參考價(jià)值,需要的小伙伴可以參考一下
    2022-05-05
  • Qt實(shí)現(xiàn)字幕無(wú)間隙滾動(dòng)效果

    Qt實(shí)現(xiàn)字幕無(wú)間隙滾動(dòng)效果

    這篇文章主要為大家詳細(xì)介紹了如何利用Qt實(shí)現(xiàn)字幕無(wú)間隙滾動(dòng)效果,文中的實(shí)現(xiàn)過(guò)程講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下
    2022-11-11
  • c++中的const_cast用法大全

    c++中的const_cast用法大全

    const_cast轉(zhuǎn)換符是用來(lái)移除變量的const或volatile限定符。對(duì)于后者,我不是太清楚,因?yàn)樗婕暗搅硕嗑€(xiàn)程的設(shè)計(jì),今天重點(diǎn)給大家介紹c++中的const_cast用法大全,需要的朋友參考下吧
    2021-07-07
  • 詳解C++編程中的sizeof運(yùn)算符與typeid運(yùn)算符

    詳解C++編程中的sizeof運(yùn)算符與typeid運(yùn)算符

    這篇文章主要介紹了C++編程中的sizeof運(yùn)算符與typeid運(yùn)算符,是C++入門(mén)學(xué)習(xí)中的基礎(chǔ)知識(shí),需要的朋友可以參考下
    2016-01-01
  • C++實(shí)現(xiàn)合并排序的方法

    C++實(shí)現(xiàn)合并排序的方法

    這篇文章主要介紹了C++實(shí)現(xiàn)合并排序的方法,實(shí)例分析了合并排序的原理與相關(guān)實(shí)現(xiàn)技巧,需要的朋友可以參考下
    2015-07-07
  • Qt線(xiàn)程池QThreadPool的使用詳解

    Qt線(xiàn)程池QThreadPool的使用詳解

    本文主要介紹了Qt線(xiàn)程池QThreadPool的使用詳解,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2022-08-08
  • C/C++實(shí)現(xiàn)線(xiàn)性順序表的示例代碼

    C/C++實(shí)現(xiàn)線(xiàn)性順序表的示例代碼

    使用順序存儲(chǔ)結(jié)構(gòu)的線(xiàn)性存儲(chǔ)結(jié)構(gòu)的表為線(xiàn)性順序表。本文將分別利用C語(yǔ)言和C++實(shí)現(xiàn)線(xiàn)性順序表,文中示例代碼講解詳細(xì),需要的可以參考一下
    2022-05-05
  • C語(yǔ)言中結(jié)構(gòu)體(struct)的幾種初始化方法

    C語(yǔ)言中結(jié)構(gòu)體(struct)的幾種初始化方法

    相信大家都知道struct結(jié)構(gòu)體是C語(yǔ)言中非常重要的復(fù)合類(lèi)型,初始化的方法很多,那么小編下面對(duì)這些方法進(jìn)行總結(jié),便于自己和大家以后查閱,有需要的可以參考借鑒。
    2016-08-08
  • C/C++中不定參數(shù)的使用詳解

    C/C++中不定參數(shù)的使用詳解

    這篇文章主要為大家詳細(xì)介紹了C/C++中不定參數(shù)的使用的相關(guān)知識(shí),文中的示例代碼講解詳細(xì),具有一定的借鑒價(jià)值,感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下
    2023-12-12

最新評(píng)論