首页 › 分类存档 › 线程间通信

pthread_barrier_init,pthread_barrier_wait简介

第七根弦 2016 年 3 月 16 日 UC, 线程间通信 0

pthread_barrier 系列函数在<pthread.h>中定义，用于多线程的同步，它包含三个函数：

–pthread_barrier_init()
–pthread_barrier_wait()
–pthread_barrier_destroy()

那么pthread_barrier_*是用来做什么的？这三个函数又怎么配合使用呢？

pthread_barrier_*其实只做且只能做一件事，就是充当栏杆（barrier意为栏杆)。形象的说就是把先后到达的多个线程挡在同一栏杆前，直到所有线程到齐，然后撤下栏杆同时放行。1）init函数负责指定要等待的线程个数；2） wait()函数由每个线程主动调用，它告诉栏杆“我到起跑线前了”。wait(）执行末尾栏杆会检查是否所有人都到栏杆前了，如果是，栏杆就消失所有线程继续执行下一句代码；如果不是，则所有已到wait()的线程停在该函数不动，剩下没执行到wait()的线程继续执行；3）destroy函数释放init申请的资源。
继续阅读 »

一个跨WINDOWS LINUX平台的线程类

第七根弦 2016 年 2 月 26 日 线程间通信 0

跨平台线程类,需要增加宏定义
Windows平台增加宏DX_WINDOWS
Linux平台增加宏DX_LINUX
继续阅读 »

编程思想之多线程与多进程——以操作系统的角度述说线程与进程

第七根弦 2015 年 12 月 31 日 线程间通信, 进程间通信 0

什么是线程

什么是线程？线程与进程与有什么关系？这是一个非常抽象的问题，也是一个特别广的话题，涉及到非常多的知识。我不能确保能把它讲的话，也不能确保讲的内容全部都正确。即使这样，我也希望尽可能地把他讲通俗一点，讲的明白一点，因为这是个一直困扰我很久的，扑朔迷离的知识领域，希望通过我的理解揭开它一层一层神秘的面纱。
继续阅读 »

OS: 生产者消费者问题(多线程+互斥量+条件变量)

第七根弦 2015 年 10 月 27 日 UC, 线程间通信 0

一. 引子

用多进程解决生产着消费者问题之后，再尝试多线程方法，才知道多线程多么地方便。多线程方案的易用性，一方面得益于强大的条件变量。赞，太好用了！

二. 思路

互斥量实际上相当于二元信号量，它是纯天然适合生产者消费者问题的解决方案，使用互斥量可以很好地描述生产者或者消费者独占缓冲区的特点。
不过互斥量的能力也仅此而已，如果需要在使用线程方案时提供更复杂的逻辑，则需要配合使用条件变量。生产者要求在缓冲区不满的情况下才能生产，我用 notFull 条件变量表示这种情况；消费者要求在缓冲区不空的情况下才能消费，我用 notEmpty 条件描述这种情况。
继续阅读 »

linux c++线程池的实现

第七根弦 2015 年 7 月 31 日 UC, 线程间通信 0

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

C++
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 年 3 月 3 日 线程间通信 0

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

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

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

继续阅读 »

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

第七根弦 2015 年 1 月 14 日 UC, 线程间通信 0

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

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

第七根弦 2015 年 1 月 14 日 UC, 线程间通信 0

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

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

第七根弦 2015 年 1 月 14 日 UC, 线程间通信 0
epoll是linux下高并发服务器的完美方案，因为是基于事件触发的，所以比select快的不只是一个数量级。
单线程epoll，触发量可达到15000，但是加上业务后，因为大多数业务都与数据库打交道，所以就会存在阻塞的情况，这个时候就必须用多线程来提速。

继续阅读 »

高并发的epoll+多线程

第七根弦 2015 年 1 月 14 日 UC, 线程间通信 0

epoll是linux下高并发服务器的完美方案，因为是基于事件触发的，所以比select快的不只是一个数量级。
单线程epoll，触发量可达到15000，但是加上业务后，因为大多数业务都与数据库打交道，所以就会存在阻塞的情况，这个时候就必须用多线程来提速。
下面是来一个网络连接创建一个线程处理业务，业务处理完，线程销毁。实际测试结果不是很理想，在没有业务的时候的测试结果是2000个/s
继续阅读 »