多线程编程指南

生成方和使用者问题示例

示例 8–2 说明了生成方和使用者位于不同进程时的生成方和使用者问题。主例程将与其子进程共享的全零内存段映射到其地址空间。请注意,必须调用 mutex_init()cond_init(),因为同步变量的 type 为 USYNC_PROCESS

创建子进程是为了运行使用者,父进程则运行生成方。

此示例还说明了生成方和使用者的驱动程序。producer_driverstdin 读取字符并调用 producerconsumer_driver 通过调用 consumer 来获取字符并将这些字符写入 stdout 中。

示例 8–2 的数据结构与用于解析条件变量的数据结构相同。请参见嵌套锁定和单链接列表的结合使用示例


示例 8–2 使用 USYNC_PROCESS 时的生成方和使用者问题

main() {

    int zfd;

    buffer_t *buffer;



    zfd = open(“/dev/zero”, O_RDWR);

    buffer = (buffer_t *)mmap(NULL, sizeof(buffer_t),

        PROT_READ|PROT_WRITE, MAP_SHARED, zfd, 0);

    buffer->occupied = buffer->nextin = buffer->nextout = 0;



    mutex_init(&buffer->lock, USYNC_PROCESS, 0);

    cond_init(&buffer->less, USYNC_PROCESS, 0);

    cond_init(&buffer->more, USYNC_PROCESS, 0);

    if (fork() == 0)

        consumer_driver(buffer);

    else

        producer_driver(buffer);

}



void producer_driver(buffer_t *b) {

    int item;



    while (1) {

        item = getchar();

        if (item == EOF) {

            producer(b, `\0');

            break;

        } else

            producer(b, (char)item);

    }

}



void consumer_driver(buffer_t *b) {

    char item;



    while (1) {

        if ((item = consumer(b)) == '\0')

            break;

        putchar(item);

    }

}

创建子进程是为了运行使用者,父进程则运行生成方。