青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

The Fourth Dimension Space

枯葉北風寒,忽然年以殘,念往昔,語默心酸。二十光陰無一物,韶光賤,寐難安; 不畏形影單,道途阻且慢,哪曲折,如渡飛湍。斬浪劈波酬壯志,同把酒,共言歡! -如夢令

再探多線程經典生產者與消費者問題

所謂進步就是與知識的緣分與不期而遇,本來選嵌入式課程是為了學習嵌入式應用方面的知識,沒想到竟然把生產者消費者問題學懂了。其實程序中最核心的部分是讀者與寫著在臨界區部分的代碼,用三個信號量鎖住線程使得同一時刻只能有一個線程進入臨界區。
本程序中寫者與寫者互斥,讀者與讀者互斥,寫者與讀者也互斥。
其實這個程序還可以提高效率,讓讀者與寫著不互斥,實現時只需在讀者與寫者線程中使用獨立的二值信號量即可。
本程序在fedora14(Linux環境)下實現.
//coded by abilitytao 
//2012.6.2
//department of computer science ,Nanjing university.
//advisor:professor Jianxin Yu
//aided by Junjie Ye and XiaoLin Ma 

#include
<stdio.h>
#include
<stdlib.h>
#include
<unistd.h>
#include
<fcntl.h>
#include
<pthread.h>
#include
<errno.h>
#include
<semaphore.h>
#include
<sys/ipc.h>
#include
<sys/types.h>
#include
<sys/stat.h>
#include
<string.h>



#define BUFFER_SIZE 8 //attention: it shoud be at least ONE! 
#define REAL_BUFFER (BUFFER_SIZE+2)

#define RUN_TIME 2 //run time : programme terminate after <RUN_TIME> seconds 

#define WRITER_NUM 4  //define the number of writer
#define READER_NUM 3  //define the number of reader





//////////////////////////////////////////////QUEUE/////////////////////////////////////////////////////
struct node
{
    
char data[64];
}
queue[REAL_BUFFER];
int front;
int rear;
int nQueue;//the number the queue contains

struct node rand_one_node()
{
    
struct node ans;
    
int i;
    
for(i= 0 ;i< 9 ;i++)
    
{
        
int tem = rand()%10;
        ans.data[i]
='0'+tem;
    }

    ans.data[
9]=' ';
    
for(i = 10; i < 64 ; i++)
    
{
        
int tem = rand()%26;
        ans.data[i]
='a'+tem;
    }

    
return ans;
}

void print_node(struct node x)
{
    
int i;
    
for(i = 0;i< 64 ;i++)
    printf(
"%c",x.data[i]);
}


void queue_init()
{
    front 
= 1;
    rear  
= 0;
    nQueue 
= 0;
}

int is_queue_full(void)
{
    
if( (front + 1% REAL_BUFFER == rear )
        
return 1;
    
else
        
return 0;
}

int is_queue_empty(void)
{
    
if( (rear + 1)% REAL_BUFFER == front )
        
return 1;
    
else
        
return 0;
}

void queue_pushback(struct node x)//
{
    
if(is_queue_full())
    
{
        printf(
"the queue is full,please check it befor");
        
return ;
    }

    queue[front]
=x;
    front
+=1;
    front
%=BUFFER_SIZE + 2;
    nQueue
++;
}

struct node queue_popfirst()
{
    
if(is_queue_empty())
    
{
        printf(
"the queue is empty,please check it befor");
    }

    
else
    
{
    
        rear
+=1;
        rear
%=REAL_BUFFER;
        
return queue[rear];
        nQueue
--;
    }

}

//////////////////////////////////////END FOR QUEUE///////////////////////////////////////////


int fd;
FILE 
*file;
time_t end_time;
sem_t mutex,full,avail;




void *producer(void *arg)
{
    
int real_write;
    
int delay_time = 0;

    
while(time(NULL) < end_time)
    
{
        
        
        sem_wait(
&avail);
        sem_wait(
&mutex);
        
        
        
struct node tem = rand_one_node();//generate a node

        
//judge if the queue if full
        if(!is_queue_full())
            queue_pushback(tem);
        
//write a node into queue
        printf("\nWrite:\n");
        print_node(tem);
         printf(
"\nto the FIFO\n");
        printf(
"producer delay = %d\n",delay_time);
        
        
//judge if the queue if full
        if(is_queue_full())
            printf(
"\n******************\nthe queue is full\n******************\n\n");
        
//sleep for some time
        delay_time = (int) (rand()%190+ 10;//delay time between 10 ~ 200 ms
        usleep(delay_time);
        
        sem_post(
&full);
        sem_post(
&mutex);
    }

    pthread_exit(NULL);
}




void *customer(void *arg)
{
    
    
int i;//a counter
    int delay_time;

    
while(time(NULL) < end_time)
    
{
        sem_wait(
&full);
        sem_wait(
&mutex);

        
struct node tem;
        
//judge if the queue is empty
        if(!is_queue_empty())
            tem 
= queue_popfirst();
        
//output the node info in the file
        for(i = 0;i < 64 ;i++)
            fprintf(file,
"%c",tem.data[i]);
        fprintf(file,
"\n");

        
//read a node
        printf("\nRead:\n");
        print_node(tem);
         printf(
"\nfrom the FIFO\n");
        printf(
"reader delay = %d\n",delay_time);
        
//judge if the queue if full
        if(is_queue_empty())
            printf(
"\n******************\nthe queue is empty\n******************\n\n");
        
//sleep for some time
        delay_time = (int) (rand()%80+ 20// delay time between 20 ~ 100 ms
        usleep(delay_time);
        
        sem_post(
&avail);
        sem_post(
&mutex);

    }

    pthread_exit(NULL);
}


int main()
{
    
//init file point
    freopen("out.txt","w",stdout);    
    file 
= fopen("G2_ReaderWriter.txt","w");
    
//init the queue
    queue_init();

    
//generate run time
    srand(time(NULL));
    end_time 
= time(NULL) +RUN_TIME;
    
    pthread_t threadWriter[WRITER_NUM];
    pthread_t threadReader[READER_NUM];
    
    
//pthread_t thrd_prd_id,thrd_cst_id;
    
//pthread_t mon_th_id;

    sem_init(
&mutex,0,1);
    sem_init(
&avail,0, BUFFER_SIZE);
    sem_init(
&full,0,0);



    
int i;//counter
    
//create writer thread
    for(i = 0 ;i < WRITER_NUM ; i++ )
        pthread_create(
&threadWriter[i], NULL, producer, NULL);
    
//create reader thread
    for(i = 0 ;i < READER_NUM ; i++ )
        pthread_create(
&threadReader[i], NULL, customer, NULL);
    
//wait for quit of writer
    for(i =0 ;i<WRITER_NUM ;i++)
        pthread_join(threadWriter[i],NULL);
    
//wait for quit of reader    
    for(i = 0;i<READER_NUM ;i++)
        pthread_join(threadReader[i],NULL);    

    fclose(file);
//close file point
    fclose(stdout);
    
return 0;
}





PS:此為2012年嵌入式課程大作業,若助教查詢到此網頁,請核對我的信息以免誤認為是作弊.謝謝!

posted on 2012-06-04 20:26 abilitytao 閱讀(1911) 評論(3)  編輯 收藏 引用

評論

# re: 再探多線程經典生產者與消費者問題 2012-06-04 22:46 愛早起

1個宇宙,9大行星,204個國家,809個島嶼,7個大洋, 我竟還有如此榮幸,可以遇見你。


博主,你博客最上方的這句話該改了!
現在是8大行星,冥王星已經不是行星了!  回復  更多評論   

# re: 再探多線程經典生產者與消費者問題 2012-06-05 09:59 AAA

樓主,生產者可以是多個,消費者最好是一個,這樣可以避免處理的時候加鎖,另外建議你搜索下雙緩存隊列  回復  更多評論   

# re: 再探多線程經典生產者與消費者問題[未登錄] 2012-06-05 13:11 abilitytao

@愛早起
網上的名句 呵呵 尊重原創吧  回復  更多評論   

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            免费亚洲电影在线| 欧美激情中文字幕乱码免费| 国产精品视频久久久| 亚洲欧美日韩视频二区| 亚洲午夜视频在线观看| 国产性色一区二区| 免播放器亚洲一区| 欧美日本亚洲视频| 欧美亚洲视频一区二区| 久久精品国产第一区二区三区| 尤物九九久久国产精品的特点| 欧美激情欧美狂野欧美精品| 欧美日韩视频不卡| 久久久国际精品| 欧美成人精精品一区二区频| 一二三区精品| 欧美一区二区三区四区视频| 亚洲精品午夜精品| 亚洲综合第一页| 亚洲日韩视频| 午夜影院日韩| 一区二区欧美国产| 久久久高清一区二区三区| 夜夜嗨av一区二区三区四区| 欧美一区亚洲| 这里只有精品丝袜| 久久人人看视频| 午夜精品美女自拍福到在线| 美女视频黄 久久| 欧美影院久久久| 狼人天天伊人久久| 欧美中文字幕精品| 欧美日韩国内| 免费中文字幕日韩欧美| 国产精品日韩| av成人动漫| 亚洲精品一区中文| 久久电影一区| 久久精品91| 国产精品久久久久久影视| 亚洲韩国精品一区| 精品动漫一区二区| 亚洲专区国产精品| 亚洲无限av看| 欧美成人午夜| 欧美成人午夜激情| 一区二区三区亚洲| 午夜精品久久久久久久99黑人| 一本色道久久综合精品竹菊| 久久综合一区二区| 美女久久一区| 在线观看国产日韩| 久久久久久欧美| 久久久久九九视频| 国产亚洲欧美在线| 欧美亚洲在线播放| 久久国产精品久久国产精品| 国产精品久久久久毛片软件 | 亚洲欧洲一区| 91久久国产综合久久| 久久欧美中文字幕| 亚洲大片av| 亚洲激情自拍| 欧美—级高清免费播放| 亚洲精品久久在线| 在线一区欧美| 国产精品久久久久久亚洲调教 | 亚洲一区免费在线观看| 亚洲欧美电影院| 国产精品亚洲第一区在线暖暖韩国| 一本一本久久a久久精品牛牛影视| 亚洲午夜精品久久| 国产精品九九| 久久国产福利国产秒拍| 欧美xxx成人| 一本色道久久综合狠狠躁篇怎么玩 | 亚洲天堂第二页| 欧美一区二区三区视频| 国产一区二区三区高清| 久久婷婷成人综合色| 亚洲激情一区二区三区| 亚洲综合色激情五月| 国产欧美日韩视频在线观看| 久久精品在线播放| 亚洲激情影视| 午夜精品久久久久久久99黑人| 国产午夜一区二区三区| 欧美1级日本1级| 中文在线资源观看网站视频免费不卡 | 鲁鲁狠狠狠7777一区二区| 亚洲激情一区二区三区| 亚洲欧美日韩精品久久| 精品福利免费观看| 欧美日韩亚洲一区在线观看| 亚洲欧美日韩人成在线播放| 欧美福利小视频| 亚洲专区一区| 伊伊综合在线| 欧美亚一区二区| 另类av一区二区| 亚洲线精品一区二区三区八戒| 免费不卡在线观看av| 亚洲永久免费精品| 亚洲缚视频在线观看| 欧美四级在线观看| 久久这里只精品最新地址| 亚洲一级片在线观看| 欧美国产第二页| 久久久久欧美精品| 亚洲一区免费看| 亚洲精品资源| 亚洲福利精品| 国产亚洲欧美日韩美女| 欧美日韩一区三区| 欧美超级免费视 在线| 欧美一区三区三区高中清蜜桃| 亚洲人成77777在线观看网| 久久蜜桃资源一区二区老牛| 亚洲一区免费在线观看| 亚洲九九爱视频| 亚洲黄色免费电影| 在线播放日韩专区| 国产一区二区三区四区hd| 国产精品国产三级欧美二区| 欧美电影在线观看| 久久久久久久久岛国免费| 亚洲综合色网站| 亚洲一区二区在线免费观看| 日韩视频一区二区三区在线播放| 欧美高清免费| 欧美国产日韩一区二区在线观看| 久久国产精品一区二区三区| 午夜精品久久久久久久久| 亚洲性图久久| 亚洲免费在线电影| 亚洲一区视频| 亚洲欧美一区二区精品久久久| 一区二区三区四区五区视频| 日韩午夜av在线| 99综合视频| 亚洲视频一区二区| 亚洲午夜一级| 欧美一级大片在线免费观看| 欧美在线观看视频在线| 欧美专区18| 麻豆精品一区二区综合av| 免费成人高清在线视频| 免费看成人av| 亚洲激情网站| 中文一区字幕| 久久xxxx精品视频| 久久影音先锋| 欧美日韩你懂的| 国产精品三级视频| 黄色在线成人| 99www免费人成精品| 亚洲午夜视频| 欧美中文在线视频| 蜜臀av在线播放一区二区三区| 亚洲第一中文字幕在线观看| 亚洲日本成人| 亚洲免费综合| 麻豆九一精品爱看视频在线观看免费| 老色批av在线精品| 欧美日韩国产美| 国产女人aaa级久久久级| 国产一区二区三区成人欧美日韩在线观看 | 欧美一区二区三区免费观看| 久久精品国语| 亚洲激情啪啪| 亚洲欧美网站| 欧美激情亚洲自拍| 国产精品永久| 亚洲精品人人| 久久精品国产精品亚洲综合 | 美女国产精品| 一区二区三区国产在线| 久久精品99国产精品日本| 欧美国产日本韩| 国产欧美一区二区三区在线看蜜臀 | 久久久综合网| 国产精品久久网| 亚洲国产色一区| 欧美一区二区三区啪啪| 91久久久亚洲精品| 久久久久九九九| 国产精品成人免费精品自在线观看| 狠狠v欧美v日韩v亚洲ⅴ| 一区二区三区四区五区视频| 久久亚洲美女| 一区二区三区欧美在线| 久热精品视频| 黑人操亚洲美女惩罚| 亚洲午夜电影| 亚洲国产另类久久久精品极度| 亚洲一区在线免费观看| 欧美日韩91| 亚洲国产免费| 老妇喷水一区二区三区| 午夜欧美不卡精品aaaaa|