linux线程池封装类资源-CSDN文库

共2个文件

h：1个

cpp：1个

5星 · 超过95%的资源需积分: 10 111 浏览量 2014-10-10 15:58:53 上传评论 2 收藏 2KB RAR 举报

在Linux操作系统中，线程池是一种高效的进程管理技术，它通过预先创建一组可重用的工作线程来处理并发任务，从而避免频繁地创建和销毁线程带来的开销。本封装的"linux 线程池封装类"为开发者提供了一个方便、高效的线程池实现，以应对多任务并行执行的需求。线程池的核心概念包括以下几个方面： 1. **线程池管理**：线程池由一个主控线程管理，负责维护线程池中线程的数量，当任务到来时，根据线程池的状态决定是立即执行还是放入等待队列。 2. **任务基类**：描述的是所有可执行任务的公共接口。在这个例子中，用户需要根据具体的业务需求继承这个基类，定义自己的任务执行逻辑。基类通常包含一个或多个虚函数，如`execute()`，用于执行实际任务。 3. **条件变量（Condition Variables）**：在Linux线程池中，条件变量被用来协调线程间的协作。当线程池中的工作线程数量达到上限时，新提交的任务会被阻塞，直到有线程完成任务并释放资源。条件变量在这里起到等待和唤醒线程的作用，提高系统的并发性能。 4. **任务调度**：线程池中的任务调度策略很重要，常见的有FIFO（先进先出）、优先级调度等。调度器会根据策略将任务分配给空闲线程，或者将任务放入等待队列。 5. **线程安全**：由于线程池涉及到多线程操作，因此必须确保线程安全。这包括对共享数据的访问控制，以及正确使用锁和信号量等同步机制，防止数据竞争和死锁。 6. **线程池大小调整**：线程池的大小可以根据系统资源和应用需求动态调整。过大可能导致资源浪费，过小则可能影响并发能力。通常需要根据系统的CPU核心数和任务特性进行优化设定。 7. **任务的提交与执行**：用户通过接口向线程池提交任务，线程池会根据当前状态选择合适的执行方式。任务执行完毕后，可能会通知线程池或其他监听者。 8. **异常处理**：线程池需要处理任务执行过程中的异常情况，如任务执行失败，确保线程池的稳定运行。 9. **资源回收**：当线程池不再使用时，应正确释放所有资源，包括线程、内存等，防止内存泄漏。这个"thread"文件可能是实现线程池封装的源代码，包含了上述功能的具体实现。通过对这个源码的学习和理解，开发者可以更好地掌握线程池的原理，并根据自己的项目需求进行定制和扩展，以提高程序的并发性能和资源利用率。

资源推荐

资源详情

资源评论

收起资源包目录

thread.rar （2个子文件）

thread

threadpool.h 1KB

threadpool.cpp 3KB

#include "threadpool.h" CTask::~CTask() { } CTask::CTask() { m_nDoFlag=1; } CThreadPool::CThreadPool( int nThreadCount ) { m_nThreadCount=nThreadCount; } CThreadPool::~CThreadPool() { Fini(); } void CThreadPool::AddThread(int nCount) { } int CThreadPool::Init() { pthread_mutex_init(&m_taskMutex,NULL); pthread_mutex_init(&m_taskListMutex,NULL); pthread_mutex_init(&m_threadListMutex,NULL); pthread_cond_init(&m_taskCond,NULL); // init thread for (int i=0;i<m_nThreadCount;i++) { CThreadItem* pItem=new CThreadItem(i,this); m_threadList.push_back(pItem); } return 0; } void CThreadPool::Fini() { list<CThreadItem*>::iterator itor; for (itor=m_threadList.begin();itor!=m_threadList.end();itor++) { CThreadItem* pItem=*itor; if (pItem) { pItem->SetQuit(); } } pthread_cond_broadcast(&m_taskCond); for (itor=m_threadList.begin();itor!=m_threadList.end();itor++) { CThreadItem* pItem=*itor; if (pItem) { delete pItem; } } pthread_mutex_destroy(&m_taskMutex); pthread_mutex_destroy(&m_taskListMutex); pthread_mutex_destroy(&m_threadListMutex); } void CThreadPool::AddTask( CTask* pTask ) { if (!pTask) { return; } pthread_mutex_lock(&m_taskListMutex); m_taskList.push_back(pTask); pthread_mutex_unlock(&m_taskListMutex); pthread_cond_signal(&m_taskCond); } CThreadItem::CThreadItem(int nID,CThreadPool* pThreadPool ) { m_nID=nID; m_hThreadHandle=0; m_nThreadFlag=1; m_pThreadPool=pThreadPool; // create thread int nError=pthread_create(&m_hThreadHandle,NULL,TreatTaskThread,this); if (0!=nError) { printf("create thread failed nid:%d \n",m_nID); } else { printf("create thread nid:%d threadhandle:%lu \n",m_nID,m_hThreadHandle); } } CThreadItem::~CThreadItem() { if (m_hThreadHandle) { m_nThreadFlag=0; pthread_join(m_hThreadHandle,NULL); printf("leave the thread nID: %d threadhandle %lu \n",m_nID,m_hThreadHandle); m_hThreadHandle=0; } } void CThreadItem::OnTreatTaskThread() { while (m_nThreadFlag) { pthread_mutex_lock(&m_pThreadPool->m_taskMutex); pthread_cond_wait(&m_pThreadPool->m_taskCond, &m_pThreadPool->m_taskMutex); pthread_mutex_unlock(&m_pThreadPool->m_taskMutex); // get task and do it pthread_mutex_lock(&m_pThreadPool->m_taskListMutex); if (m_pThreadPool->m_taskList.size()>0) { CTask* pTask=m_pThreadPool->m_taskList.front(); m_pThreadPool->m_taskList.pop_front(); pthread_mutex_unlock(&m_pThreadPool->m_taskListMutex); if (pTask) { int nRet=pTask->Do(); printf("task being treated by thread handle :%lu \n",m_hThreadHandle); if (0==nRet) { delete pTask; } } } else { pthread_mutex_unlock(&m_pThreadPool->m_taskListMutex); } } }

评论收藏

内容反馈