沉静
  
  首页 >>  
我的日历
分类日志
友情链接
最新评论
搜索日志
访问计数
获取 RSS
我的 Blog:
youalwayscan 最新的 20 条日志
[心情留言]
[点滴积累]
[好文共赏]
[C/C+基础]
[Unix/Linux基础]
[WxWidgets]
[VC/MFC]
全站 Blog:
全站最新的 20 条日志

 

生产者/消费者问题(信号量C语言实现)[转]

   C/C+基础2005-3-29 13:56
题:请编写一个Producer线程和一个Consumer线程,两个线程共享着一个固定长度的缓冲区和该缓冲区上的一个读写索引index。Producer负责把一些随机数放到缓冲区里,Consumer则负责删除那些随机数。请用C语言中的信号量或者是Java中的线程方法来实现这一问题。

信号量的概念首先由E.W.Dijkstra在1965年提出的。semaphore(信号量)是一个大于等于零的整型变量。 对信号量有两个原子操作:-和+,DOWN( )和UP( ),SLEEP( )(和WAKEUP( ),P( )和V( ),Wait() 和Signal()。虽然它们名字都不一样,可意思都是相同的,拿down和up操作来说明。
DOWN(t) 操作
递减信号量t的值:先检查t是否大于0,若t大于0则t减去1;若t的值为0,则进程进入睡眠状态,而此时的DOWN操作并没有结束。这是原子操作,用来保证一旦一个信号量的操作开始,则在操作完成或阻塞之前别的进程不允许访问该信号量。
UP(t) 操作
递增信号量t的值:如果一个或多个进程在该信号量t上睡眠,则无法完成一个先前的DOWN操作,则由系统选择其中的一个并允许起完成它的DOWN操作。因此,对一个有进程在起上睡眠的信号量执行一次UP操作以后,该信号量的值仍旧是0,但在其上睡眠的进程却少了一个。递增信号量的值和唤醒一个进程的操作也是原子操作,不可分割的。这样做保证不会有进程因为执行UP操作而被阻塞。

/* 以下五行语句形成一个"互斥的有界缓冲区" */
#define N 100 /*number of slots in the buffer*/
typedef int semaphore;/*信号量*/
semaphore mutex=1; /*互斥信号量*/
semaphore empty=N; /*缓冲区还可以入装产品的数量,初始为N*/ /*(inNumtobefull)*/
semaphore full=0; /*缓冲区中还可以消费的产品数量*/ /*(NumcanbeConsume)*/


void producer(void){ /*Producer Thread*/
int item;
while(TRUE){
produce_item(&item);

//!p操作。empty初始值为N:初始时最多允许100个生产线程同时生产产品;当还有empty个产品入装缓冲区即满时,最多只允许empty个生产线程同时生产产品
down(&empty);

down(&mutex); /*p操作:初值为1,严格互斥条件*/
enter_item(item);
up(&mutex); /*v操作*/

//!v操作,消费者线程因此知道缓冲区还有多少产品可以消费
up(&full);
}
}
void consumer(void){ /*Consumer Thread*/
int item;
while(TRUE){

//!p操作,full初始值为0。当缓冲区还有full个产品可以消费时,最多允许full个消费者线程同时消费.
down(&full);

down(&mutex);
remove_item(&item);
up(&mutex);

//!生产者线程因此能够知道现在还有多少个产品入装缓冲区即满.
up(&empty);/
consume_item(item);
}
}


多线程程序中最简单也是最常用的同步机制要算是mutex(互斥量)了。一个mutex也就是一个信号量,它只提供两个基本操作:DOWN和UP。一旦某个线程调用了DOWN,其它线程再调用DOWN时就会被阻塞。当这个线程调用UP后,刚才阻塞在DOWN里的线程中,会有一个且仅有一个被唤醒。换句话说,对于一个给定的mutex,只有一个线程可以在DOWN和UP调用之间获取处理器时间。这里的mutex 用来保护访问的临界区,避免数据出现竞争条件。
在这个实例中,开始便定义了一个大小为100的缓冲区,然后定义整型的信号量并初始化。empty是指剩余缓冲区的容量,而full则与之相对,已占用缓冲区的大小。首先是生产者函数,produce_item(&item);生产一个产品,这时候并没有对缓冲区进行操作,接着对empty和 mutex分别DOWN操作,(注意:down(&empty)和down(&mutex)顺序不能颠倒。如果颠倒了这两个操作,会出现生产者进入睡眠状态却占用缓冲区导致消费者不能访问缓冲区的情况。)enter_item(item)指生产者把产品放入缓冲区,对mutex执行UP操作是撤消对缓冲区的保护。同理分析消费者函数。
由此看来,使用信号量很大程度上避免出现了竞争条件。当然它也有弊端,以后再说明。

标签集:TAGS:
回复Comments()点击Count()

回复Comments

{commenttime}{commentauthor}

{CommentUrl}
{commentcontent}