空间有形 梦想无限

通过这个线程池的封装来复习一下设计模式。(我会把代码在最后一篇打包)

下复习 函数对象化

这个线程池有如下特定。

cpp跨平台（这部分依赖公司保密代码不公开）

任务池可配置(默认使用std::queue 也可以用堆和循环队列实现)

函数对象化 可以多个任务共用一组线程池

可暂停 可停止 可继续

接口简单

用它来开发中等规模服务器是非常方便的

通过这个线程池的封装来复习一下设计模式。(我会把代码在最后一篇打包)

这个线程池有如下特定。

cpp跨平台（这部分依赖公司保密代码不公开）

任务池可配置(默认使用std::queue 也可以用堆和循环队列实现)

函数对象化 可以多个任务共用一组线程池

可暂停 可停止 可继续

接口简单

用它来开发中等规模服务器是非常方便的

---------------------------------

对象化的函数

<<Think in Patterns with Java>> 一书的这样解释函数对象

我们在这座一个示范

class ThreadJob
{
public:
inline virtual bool execute()
{
delete this;
return true;
}
ThreadJob() {}
};

一般自己实现未封装的线程池总要自己先定义几组不同的stdcall的线程函数。然后启动一组这样的线程。

现在不需要这样的函数了，只需要继承ThreadJob 然后重载
execute()函数。比如以下这个类就完成了一个登陆服务器的多线程测试

class MyJob : public ThreadJob
{
public:
inline virtual bool execute()
{
printf("enter exec ");
unsigned char email_len;
char email[200];
unsigned long systemid =0;
int ret;
memset(email,0,200);
read(m_so, &email_len,1);
if( email_len < 200){
printf("Email len:%d ",email_len);
ret = read(m_so, email, email_len);

printf("in myjob exec ");
printf("email:%s ",email);

if(ret == email_len)
{
printf("ret == %d ",ret);
systemid = QueryUserSysId(email, NULL);
printf("systemid %d ",systemid);
}

}else{
systemid = 0 ;
}
write(m_so,&systemid,SYSID_LEN);
close(m_s;


return ThreadJob::execute();
};

MyJob(int sock):m_so(sock){};
virtual ~MyJob(){};
protected:
int m_so;

};
#endif

main.cpp中只需要

ThreadPool thepool;

thepool.set_threadcount(100)

for(size_t i = 0 ; i<100000 ; i++){
socket so = CONNECT(..)
thepool.addjob(New MyJob(s)
}

那么我们的登陆函数就会通过子类虚函数回调被线程池执行。这样一来我们的目的就达到了。

// Authornebird
// Date 2006.08.22
// For Cross Thread Pool Class
//////////////////////////////////////////////////////////////////////
#ifndef _THREAD_H_
#define _THREAD_H_
#include "mthread.h"
#include "mutex.h"
//#include <pthread.h>

#include "threadjob.h"
#include "threadpool.h"


class ThreadPool;
class Thread //线程封装 作为ThreadPool管理对象
{
public:

inline ThreadPool * get_threadpool() {
return m_pthreadPool;
}
void run();
Thread( ThreadPool * pPool );
virtual ~Thread();

protected:

ThreadPool * m_pthreadPool ;
MThread m_thread;
MMutex m_mutex;
bool m_fquit;
};
#endif

#ifndef _THREADJOB_H_
#define _THREADJOB_H_
#include <time.h>
#include <queue>
class ThreadJob
{
public:
inline virtual bool execute()
{
delete this;
return true;
}
ThreadJob() {
time(&m_ts);
}
virtual ~ThreadJob() {}
protected:
time_t m_ts;
};

class JobPool{//抽象基类 用于内置任务池定制
public:
virtual void push(ThreadJob *)=0;
virtual ThreadJob * front()=0;
virtual void pop()=0;
virtual size_t size()=0 ;

};
class DefaultJobPool:public JobPool{ //默认任务池
public:
virtual void push(ThreadJob *);
virtual ThreadJob * front();
virtual void pop();
virtual size_t size();
private:
std::queue<ThreadJob *> jobs ;
};
#endif

// Authornebird
// Date 2006.08.22
// For Cross Thread Pool Class
//////////////////////////////////////////////////////////////////////

#ifndef _THREADPOOL_H_
#define _THREADPOOL_H_
#include <queue>
#include <vector>
#include <mthread.h>
#include <mutex.h>

//#include <unistd.h>

class Thread;

;
class ThreadPool
{
public:

void pause();
bool is_pause();
void un_pause();

inline bool is_stop() { return m_fstop; }
void add_thread(Thread* pthread);
inline long get_threadcount() {return m_nthreadcount;}

inline long get_jobcount()
{
m_mutex.Lock();
int count = m_pjobs->size();
m_mutex.Unlock();
return count;
}

void stop();
void set_threadcount(int nthreads);

inline void add_job(ThreadJob* pjob)
{
if (m_fstop)
{
delete pjob;
return;
}
m_mutex.Lock();
m_pjobs->push(pjob);
m_mutex.Unlock();
m_signal.Signal();
}

inline MSemaphore * get_object() { return & m_signal; }

ThreadPool( JobPool * JobPoolPtr = new DefaultJobPool );
virtual ~ThreadPool();

inline ThreadJob* get_next()
{

ThreadJob* p = NULL;
m_mutex.Lock();
m_signal.Wait(5000);
if (m_pjobs->size() > 0)
{
p = m_pjobs->front();
if(p != NULL){
m_pjobs->pop();
}
}
m_mutex.Unlock();
return p;
}

protected:
MSemaphore m_signal;
JobPool * m_pjobs;
std::vector< Thread* > m_threads;
MMutex m_mutex;
int m_nthreadcount;
bool m_fstop;
bool m_bPause ;
};
#endif

------------------------------------------------------

跟上Think in Patterns with java的相关章节

Command: choosing the operation at run-time

//: c06:CommandPattern.java
import java.util.*;
import com.bruceeckel.test.*;

interface Command {
  void execute();
}

class Hello implements Command {
  public void execute() {
    System.out.print("Hello ");
  }
}

class World implements Command {
  public void execute() {
    System.out.print("World! ");
  }
}

class IAm implements Command {
  public void execute() {
    System.out.print("I'm the command pattern!");
  }
}

// An object that holds commands:
class Macro {
  private List commands = new ArrayList();
  public void add(Command c) { commands.add(c); }
  public void run() {
    Iterator it = commands.iterator();
    while(it.hasNext())
      ((Command)it.next()).execute();
  }
}

public class CommandPattern extends UnitTest {
  Macro macro = new Macro();
  public void test() {
    macro.add(new Hello());
    macro.add(new World());
    macro.add(new IAm());
    macro.run();
  }
  public static void main(String args[]) {
    new CommandPattern().test();
  }
} ///:~

福建 龙岩 永定 南开 酷讯 微软 搜索 广告 推荐 IM 网络应用 技术研发，工程管理 音乐 旅游 IPhone

• 主页面
• 文章汇整
• 文件夹
• 网站链接

• The Production/Production Capability (P/PC) Balance
• Term sheet
• beanstalk 任务队列
• 适合创业的好事情的判断 123
• IT创业团队难点废话
• 再说一下迅雷
• 世界是平的 不仅仅对制造业和贸易以及资本流动 对软件人才是更大的机会
• test
• ace(not acer:)) layer
• 爱体(理疗)健康的经营情况
• 博客阅读后感 从ACE到其它
• Can you do it better?
• 招什么样的人
• B2C网站的服务观念太差了
• 回忆：我为什么高考没有报计算机系

最新评论

• 无言: 警察同志你好！我今天被人一下子骗了七百块钱，本来是想贷款做点小生意的，可是对方要求我先打两百做为一个查资料的费用，后来他们把钱带过来又要求交什么保证金，一下子被骗七百块，唉！也不知道今天怎...
• 参展商: 我是参展商，十一月五日，我参加大朗毛织展销会，被一个骗子和他的同伙打劫了。因为当时碍于面子也没有报案，我希望你们警方能把你们的治安搞好...........我再提供一个抢劫团伙的电话号码线...
• 吕医生: 你好,我是专业的脊椎病医生,想到您那工作或合作,这是我的博客,可以看看http://space.mosh.cn/member/u210697,我的电话86825610
• 漆黑之天使: 警察同志你们好，我这里是东莞市罗沙上龄后街2号，在我们家前面有一家空房，一直没人进去住（这所空房堑头管理部门肯定知道）；也不记得从什么时候开始了，老是有人偷偷跑进去住，都是一些小偷们；开始...
• 漆黑之天使: 警察同志你们好，我这里是东莞市罗沙上龄后街2号，在我们家前面有一家空房，一直没人进去住（这所空房堑头管理部门肯定知道）；也不记得从什么时候开始了，老是有人偷偷跑进去住，都是一些小偷们；开始...
• lunny: 不过，支持！
• 李今朝: 想起就气``本来逢国庆是个好日子``到朋友东莞中堂这边来玩玩`打算回厂上班的`结果电话昨天才买滴``卡都还只打两个电话发了几条信息`结果今天上午11点到中堂蕉利南站坐了67路工交车人太多了...
• zhuoying: 大公司很难有个人的成功。 支持！
• srz: 有魄力，师兄加油
• achang: 创业的确是一个成功男人挥之不去的梦……

• 生活 [62]
• 互联网 [46]
• 创业赚钱 [1]
• 技术 [54]
• 工作 [37]
• 学习 [10]
• 心情 [11]
• 工程 [5]
• 关于我 [2]
• 一般分类 [2]
• 代码 [9]
• 作品 [0]
• 设计 [0]
• 转贴 [0]

• RSS 0.90
• RSS 1.0
• RSS 2.0
• Atom