生产者消费者问题是计算机中一类重要的模型,主要描述的是:生产者往缓冲区中放入产品、消费者取走产品。生产者和消费者指的可以是线程也可以是进程。 生产者消费者问题的难点在于: 为了缓冲区数据的安全性,一次只允许一个线程进入缓冲区,它就是所谓的临界资源。 生产者往缓冲区放物品时,如果缓冲区已满,那么需要等...
分类:
系统相关 时间:
2014-10-07 22:12:34
阅读次数:
305
我们不止一次写过这种代码: { mutex_.lock(); //XXX if(....) return; //XXX mutex_.unlock();
} 显然,这段代码中我们忘记了解锁。那么如何防止这种情况,我们采用和智能指针相同的策略,把加锁和解锁的过程封装在一个对象中。 实现“对象生命期”等...
分类:
系统相关 时间:
2014-10-07 21:53:24
阅读次数:
215
这里,我们需要将缓冲区封装起来,然后让缓冲区与线程想连接,所以我们需要一个相应的接口。在Buffer中,我们需要想对应的一把锁与两个条件变量。当满足队列为空时,消费者等待,反之,生产者等待。Buffer的声明如下: 1 #ifndef BUFFER_H 2 #define BUFFER_H 3 4....
分类:
系统相关 时间:
2014-10-07 19:02:13
阅读次数:
278
我们封装好了Buffer后,却不知道具体要多少个线程,一个一个线程的去关联Buffer太繁琐了。那么,我们是不是可以讲Buffer与线程的一个队列封装在一起呢 ?由于vector中不能存放Thread,所以,我们应在vector中添加相应的Thread *,这样,就可以完成封装了。声明代码如下: 1...
分类:
系统相关 时间:
2014-10-07 17:47:43
阅读次数:
274
本博文讨论Linux中的条件变量Condition的封装;条件变量Condition 主要描述的是 线程间 的同步,即协作关系。Linux中的条件变量通常涉及以下几个函数:int pthread_cond_init(pthread_cond_t *cond, pthread_condattr_t *...
分类:
系统相关 时间:
2014-10-06 23:40:40
阅读次数:
377
本篇我们将讨论线程Thread的封装;一、线程类(Thread):注意:1、线程在默认情况下 是 joinable(可结合状态),需要手工调用 join函数(将其回收),也可以将其设置为detachable(分离状态),线程运行完毕后自动消亡;2、Thread类采用static函数作为 pthrea...
分类:
系统相关 时间:
2014-10-06 23:25:50
阅读次数:
288
声明代码如下: 1 #ifndef THREAD_H 2 #define THREAD_H 3 4 #include "NonCopyable.h" 5 #include 6 #include 7 8 class Thread : NonCopyable 9 {10 public:11 ...
分类:
系统相关 时间:
2014-10-06 23:06:30
阅读次数:
225
本文对pthread_mutex_t 进行简易的封装;互斥锁主要用于互斥,描述的是一种竞争关系,主要是一个 一种资源或者代码, 在一段时间内 至多能被一个程序访问。而条件变量主要用于线程间同步, 描述的是一种协作关系。Linux中互斥锁的应用比较简单,通用的有以下几个函数:1 int pthread...
分类:
系统相关 时间:
2014-10-06 22:44:20
阅读次数:
241
声明代码如下: 1 #ifndef CONDITION_H 2 #define CONDITION_H 3 4 #include 5 #include "noncopyable.h" 6 7 class MutexLock; 8 9 10 class Condition : NonCopya...
分类:
系统相关 时间:
2014-10-06 22:00:00
阅读次数:
265
由于pthread系列的函数都是成功时返回0,我们需要一段判断处理错误的代码:#define TINY_CHECK(exp)\ if(!exp)\ { \ fprintf(stderr, "File : %s, Line : %d Exp : ...
分类:
系统相关 时间:
2014-10-06 21:11:10
阅读次数:
248