zoukankan      html  css  js  c++  java
  • thread同步测试

    1 编译运行附件中的代码,提交运行结果截图,并说明程序功能

    程序功能:
    生产者消费者模型,假定有两个线程,一个消费者线程,一个生产者线程。一个模拟生产者行为,一个模拟消费者行为。两个线程同时操作一个共享资源(一般称之为汇聚),生产向其中添加产品,消费者从中消费掉产品。 2 修改代码,把同步资源个数减少为3个,把使用资源的线程增加到 (你的学号%3 + 4)个,编译代码,提交修改后的代码和运行结果截图。

     修改代码为:

    #include <stdio.h>
    #include <pthread.h>
    #include <stdlib.h>
    #include <semaphore.h>
    
    #define NUM 3
    int queue[NUM];
    sem_t blank_number, product_number;
    
    void *producer ( void * arg )
    {
        static int p = 0;
    
        for ( ;; ) {
            sem_wait( &blank_number );
            queue[p] = rand() % 1000;
            printf("Product %d \n", queue[p]);
            p = (p+1) % NUM;
            sleep ( rand() % 5);
            sem_post( &product_number );
        }
    }
    void *consumer ( void * arg )
    {
    
        static int c = 0;
        for( ;; ) {
            sem_wait( &product_number );
            printf("Consume %d\n", queue[c]);
            c = (c+1) % NUM;
            sleep( rand() % 5 );
            sem_post( &blank_number );
        }
    }
    
    int main(int argc, char *argv[] )
    {
        pthread_t pid, cid,cid1,cid2,cid3,cid4,cid5;
        
        sem_init( &blank_number, 0, NUM );
        sem_init( &product_number, 0, 0);
        pthread_create( &pid, NULL, producer, NULL);
        pthread_create( &cid, NULL, consumer, NULL);
        pthread_create( &cid, NULL, consumer, NULL);//创建消费者线程
        pthread_create( &cid1, NULL, consumer, NULL);//创建消费者线程
        pthread_create( &cid2, NULL, consumer, NULL);//创建消费者线程
        pthread_create( &cid3, NULL, consumer, NULL);//创建消费者线程
        pthread_create( &cid4, NULL, consumer, NULL);//创建消费者线程
        pthread_create( &cid5, NULL, consumer, NULL);
        pthread_join( pid, NULL );
        pthread_join( cid, NULL );
        pthread_join( cid, NULL );//等待消费者线程执行完
        pthread_join( cid1, NULL );//等待消费者线程执行完
        pthread_join( cid2, NULL );//等待消费者线程执行完
        pthread_join( cid3, NULL );//等待消费者线程执行完
        pthread_join( cid4, NULL );//等待消费者线程执行完
        pthread_join( cid5, NULL );
        sem_destroy( &blank_number );
        sem_destroy( &product_number );
        return 0;
    }

    运行结果:

  • 相关阅读:
    Ubuntu(Linux) + mono + jexus +asp.net MVC3 部署
    爬虫代理
    爬取文件时,对已经操作过的URL进行过滤
    Scrapy项目创建以及目录详情
    Scrapy 框架 安装
    爬虫案例
    爬虫基础以及 re,BeatifulSoup,requests模块使用
    Django_Admin操作
    django 权限管理permission
    Node--01
  • 原文地址:https://www.cnblogs.com/zhaojingle/p/15555273.html
Copyright © 2011-2022 走看看