6 Мы объявляем три семафора типа sem_t, и теперь это сами семафоры, а не указатели на них.Выделение семафоров
Листинг 10.12. Функция main задачи с несколькими производителями
//pxsem/prodcons3.c
1 #include "unpipc.h"
2 #define NBUFF 10
3 #define MAXNTHREADS 100
4 int nitems, nproducers; /* только для чтения производителем и потребителем */
5 struct { /* общие данные */
6 int buff[NBUFF];
7 int nput;
8 int nputval;
9 sem_t mutex, nempty, nstored; /* семафоры, а не указатели */
10 } shared;
11 void *produce(void *), *consume(void *);
12 int
13 main(int argc, char **argv)
14 {
15 int i, count[MAXNTHREADS];
16 pthread_t tid_produce[MAXNTHREADS], tid_consume;
17 if (argc != 3)
18 err_quit("usage: prodcons3 <#items> <#producers>");
19 nitems = atoi(argv[1]);
20 nproducers = min(atoi(argv[2]), MAXNTHREADS);
21 /* инициализация трех семафоров */
22 Sem_init(&shared.mutex, 0, 1);
23 Sem_init(&shared.nempty, 0, NBUFF);
24 Sem_init(&shared.nstored, 0, 0);
25 /* создание всех производителей и одного потребителя */
26 Set_concurrency(nproducers + 1);
27 for (i = 0; i < nproducers; i++) {
28 count[i] = 0;
29 Pthread_create(&tid_produce[i], NULL, produce, &count[i]);
30 }
31 Pthread_create(&tid_consume, NULL, consume, NULL);
32 /* ожидание завершения всех производителей и потребителя */
33 for (i = 0; i < nproducers; i++) {
34 Pthread_join(tid_produce[i], NULL);
35 printf("count[%d] = %d\n", i, count[i]);
36 }
37 Pthread_join(tid_consume, NULL);
38 Sem_destroy(&shared.mutex);
39 Sem_destroy(&shared.nempty);
40 Sem_destroy(&shared.nstored);
41 exit(0);
42 }