给代码：#include <stdio.h> #include <string.h> #include <errno.h> #include <pthread.h> #include <semaphore.h> #define SUMSIZE 100 #define BUFSIZE 8 static int bufin=0; static int bufout=0; static pthread_mutex_t buffer_lock=PTHREAD_MUTEX_INITIALIZER; static int buffer[BUFSIZE]; void put_item(int item){ pthread_mutex_lock(&buffer_lock); buffer[bufin]=item; bufin=(bufin+1)%BUFSIZE; pthread_mutex_unlock(&buffer_lock); return; } void get_item(int *itemp){ pthread_mutex_lock(&buffer_lock); *itemp=buffer[bufout]; bufout=(bufout+1)%BUFSIZE; pthread_mutex_unlock(&buffer_lock); return; } int sum=0; sem_t items; sem_t slots; static void *producer(void *); static void *consumer(void *); main(void){ pthread_t prodid; pthread_t constid; sem_init(&items,0,0); sem_init(&slots,0,BUFSIZE); pthread_create(&prodid,NULL,producer,NULL); pthread_create(&constid,NULL,consumer,NULL); pthread_join(prodid,NULL); pthread_join(constid,NULL); printf("sum=%d\n",sum); } static void *producer(void *x){ int i; for(i=1;i<=SUMSIZE;i++){ sem_wait(&slots); put_item(i); printf("Put %d\n",i); sem_post(&items); } return NULL; } static void *consumer(void *arg2){ int i,myitem; for(i=1;i<=SUMSIZE;i++){ sem_wait(&items); get_item(&myitem); printf("\tGet %d\n",myitem); sem_post(&slots); sum+=myitem; } return NULL; }添加注释

#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <pthread.h>
#include <semaphore.h>

#define SUMSIZE 100
#define BUFSIZE 8

static int bufin = 0;  // 缓冲区中待写入数据的位置
static int bufout = 0;  // 缓冲区中待读取数据的位置
static pthread_mutex_t buffer_lock = PTHREAD_MUTEX_INITIALIZER;  // 缓冲区锁
static int buffer[BUFSIZE];  // 缓冲区

// 向缓冲区中写入数据
void put_item(int item) {
    pthread_mutex_lock(&buffer_lock);
    buffer[bufin] = item;
    bufin = (bufin + 1) % BUFSIZE;
    pthread_mutex_unlock(&buffer_lock);
    return;
}

// 从缓冲区中读取数据
void get_item(int *itemp) {
    pthread_mutex_lock(&buffer_lock);
    *itemp = buffer[bufout];
    bufout = (bufout + 1) % BUFSIZE;
    pthread_mutex_unlock(&buffer_lock);
    return;
}

int sum = 0;  // 累加器

sem_t items;  // 用于同步待处理数据项数目
sem_t slots;  // 用于同步缓冲区空闲位置数目

// 生产者线程函数
static void *producer(void *);

// 消费者线程函数
static void *consumer(void *);

int main(void) {
    pthread_t prodid;
    pthread_t constid;

    sem_init(&items, 0, 0);
    sem_init(&slots, 0, BUFSIZE);

    pthread_create(&prodid, NULL, producer, NULL);
    pthread_create(&constid, NULL, consumer, NULL);

    pthread_join(prodid, NULL);
    pthread_join(constid, NULL);

    printf("sum = %d\n", sum);

    return 0;
}

// 生产者线程函数
static void *producer(void *x) {
    int i;
    for (i = 1; i <= SUMSIZE; i++) {
        sem_wait(&slots);  // 申请一个缓冲区空闲位置
        put_item(i);  // 将数据写入缓冲区
        printf("Put %d\n", i);
        sem_post(&items);  // 通知消费者线程可以取出一个数据项
    }
    return NULL;
}

// 消费者线程函数
static void *consumer(void *arg2) {
    int i, myitem;
    for (i = 1; i <= SUMSIZE; i++) {
        sem_wait(&items);  // 等待一个数据项可用
        get_item(&myitem);  // 从缓冲区中获取数据
        printf("\tGet %d\n", myitem);
        sem_post(&slots);  // 释放一个缓冲区空闲位置
        sum += myitem;  // 将数据累加到sum中
    }
    return NULL;
}

注释如下：

#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <pthread.h>
#include <semaphore.h>

#define SUMSIZE 100  // 待处理数据项数目
#define BUFSIZE 8  // 缓冲区大小

static int bufin = 0;  // 缓冲区中待写入数据的位置
static int bufout = 0;  // 缓冲区中待读取数据的位置
static pthread_mutex_t buffer_lock = PTHREAD_MUTEX_INITIALIZER;  // 缓冲区锁
static int buffer[BUFSIZE];  // 缓冲区

// 向缓冲区中写入数据
void put_item(int item) {
    pthread_mutex_lock(&buffer_lock);  // 申请缓冲区锁
    buffer[bufin] = item;  // 将数据写入缓冲区
    bufin = (bufin + 1) % BUFSIZE;  // 更新待写入数据的位置
    pthread_mutex_unlock(&buffer_lock);  // 释放缓冲区锁
    return;
}

// 从缓冲区中读取数据
void get_item(int *itemp) {
    pthread_mutex_lock(&buffer_lock);  // 申请缓冲区锁
    *itemp = buffer[bufout];  // 从缓冲区中获取数据
    bufout = (bufout + 1) % BUFSIZE;  // 更新待读取数据的位置
    pthread_mutex_unlock(&buffer_lock);  // 释放缓冲区锁
    return;
}

int sum = 0;  // 累加器

sem_t items;  // 用于同步待处理数据项数目
sem_t slots;  // 用于同步缓冲区空闲位置数目

// 生产者线程函数
static void *producer(void *);

// 消费者线程函数
static void *consumer(void *);

int main(void) {
    pthread_t prodid;
    pthread_t constid;

    sem_init(&items, 0, 0);  // 初始化待处理数据项数目为0
    sem_init(&slots, 0, BUFSIZE);  // 初始化缓冲区空闲位置数目为缓冲区大小

    pthread_create(&prodid, NULL, producer, NULL);  // 创建生产者线程
    pthread_create(&constid, NULL, consumer, NULL);  // 创建消费者线程

    pthread_join(prodid, NULL);  // 等待生产者线程结束
    pthread_join(constid, NULL);  // 等待消费者线程结束

    printf("sum = %d\n", sum);

    return 0;
}

// 生产者线程函数
static void *producer(void *x) {
    int i;
    for (i = 1; i <= SUMSIZE; i++) {
        sem_wait(&slots);  // 申请一个缓冲区空闲位置
        put_item(i);  // 将数据写入缓冲区
        printf("Put %d\n", i);
        sem_post(&items);  // 通知消费者线程可以取出一个数据项
    }
    return NULL;
}

// 消费者线程函数
static void *consumer(void *arg2) {
    int i, myitem;
    for (i = 1; i <= SUMSIZE; i++) {
        sem_wait(&items);  // 等待一个数据项可用
        get_item(&myitem);  // 从缓冲区中获取数据
        printf("\tGet %d\n", myitem);
        sem_post(&slots);  // 释放一个缓冲区空闲位置
        sum += myitem;  // 将数据累加到sum中
    }
    return NULL;
}

这段代码实现了一个生产者-消费者模型，使用了缓冲区和信号量进行同步。注释中解释了每一行代码的作用。