线程池 | 第七根弦的技术博客

linux c++线程池的实现

第七根弦 2015.07.31 UC, 线程间通信 0

线程池的原理大家都知道，直接上代码了^_^
test.cpp

#include "Thread.h"   
#include <iostream>   
#include <cstdio>
#include <cstdlib>
  
class CMyTask: public CTask  
{  
public:  
    CMyTask(){}  
      
    inline int Run()  
    {  
        printf("%s\n", (char*)this->m_ptrData);  
        sleep(10);  
        return 0;  
    }  
};  
  
int main()  
{  
    CMyTask taskObj;  
      
    char szTmp[] = "this is the first thread running";  
    taskObj.SetData((void*)szTmp);  
    CThreadPool threadPool(10);  
      
    for(int i = 0; i < 20; i++)  
    {  
        threadPool.AddTask(&taskObj);  
    }  
      
    while(1)  
    {  
        printf("there are still %d tasks need to handle\n", threadPool.getTaskSize());  
        if (threadPool.getTaskSize() == 0)  
        {  
            if (threadPool.StopAll() == -1)  
            {     
                printf("Now I will exit from main\n");  
                exit(0);  
            }  
        }  
        sleep(2);  
    }
    return 0;  
}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

#include "Thread.h"

#include <iostream>

#include <cstdio>

#include <cstdlib>

class CMyTask: public CTask

{

public:

CMyTask(){}

inline int Run()

{

printf("%s\n", (char*)this->m_ptrData);

sleep(10);

return 0;

}

};

int main()

{

CMyTask taskObj;

char szTmp[] = "this is the first thread running";

taskObj.SetData((void*)szTmp);

CThreadPool threadPool(10);

for(int i = 0; i < 20; i++)

{

threadPool.AddTask(&taskObj);

}

while(1)

{

printf("there are still %d tasks need to handle\n", threadPool.getTaskSize());

if (threadPool.getTaskSize() == 0)

{

if (threadPool.StopAll() == -1)

{

printf("Now I will exit from main\n");

exit(0);

}

sleep(2);

}

return 0;

}

继续阅读 »

线程池（领导者-追随者，生产者-消费者等）小结

第七根弦 2015.03.03 线程间通信 0

领导者/追随者模型（Leader/Followers）

这几天翻了些文章，发现对领导者/追随者模型说的比较少，下面就这个模型打个比方：

话说一个地方有一群有组织无纪律的人从事山贼这个很有前途的职业。
一般就是有一个山贼在山路口察看，其他人在林子里面睡觉。
假如发现有落单的过往客商，望风的山贼就会弄醒一个睡觉的山贼，然后自己去打劫。
醒来的山贼接替作望风的事情。
打劫的山贼搞定以后，就会去睡觉，直到被其他望风的山贼叫醒来望风为止。
有时候过往客商太多，而山贼数量不够，有些客商就能侥幸平安通过山岭(所有山贼都去打劫其他客商了)。

继续阅读 »

对libevent+多线程服务器模型的C++封装类

第七根弦 2015.01.20 libevent, UC 0

最近在看memcached的源码，觉得它那种libevent+多线程的服务器模型真的很不错，我将这个模型封装成一个C++类，根据我的简单测试，这个模型的效率真的很不错，欢迎大家试用。
继续阅读 »

boost高并发网络框架+线程池

第七根弦 2015.01.14 UC, 线程间通信 0

boost的官方例子，有单线程的网络框架，httpserver2是线程池的。下面参照网上某人的代码修改了一点（忘了哪位大仙的代码了）
测试工具，适用stressmark，测试效果非常好， 9000个/s
继续阅读 »

高并发的epoll+线程池，业务在线程池内

第七根弦 2015.01.14 UC, 线程间通信 0

epoll是linux下高并发服务器的完美方案，因为是基于事件触发的，所以比select快的不只是一个数量级。
单线程epoll，触发量可达到15000，但是加上业务后，因为大多数业务都与数据库打交道，所以就会存在阻塞的情况，这个时候就必须用多线程来提速。
业务在线程池内，这里要加锁才行。测试结果2300个/s
继续阅读 »

高并发的epoll+线程池，epoll在线程池内

第七根弦 2015.01.14 UC, 线程间通信 0

epoll是linux下高并发服务器的完美方案，因为是基于事件触发的，所以比select快的不只是一个数量级。

单线程epoll，触发量可达到15000，但是加上业务后，因为大多数业务都与数据库打交道，所以就会存在阻塞的情况，这个时候就必须用多线程来提速。

继续阅读 »

第七根弦的技术博客

linux c++线程池的实现

线程池（领导者-追随者，生产者-消费者等）小结

对libevent+多线程服务器模型的C++封装类

boost高并发网络框架+线程池

高并发的epoll+线程池，业务在线程池内

高并发的epoll+线程池，epoll在线程池内

高并发的epoll+多线程

一个简单的linux线程池

网络服务端开发小结(短连接、长连接、进程池、线程池)

pthread_cond

近期文章

近期评论

归档

分类

功能