Книга: UNIX: взаимодействие процессов

Блокировки чтения-записи

Блокировки чтения-записи

Пpoгрaммa, использующая блокировки чтения-записи, является слегка измененной версией программы с взаимными исключениями Posix. Поток должен установить блокировку файла, прежде чем увеличивать общий счетчик.

В листинге А.21 приведен текст функции main, а в листинге А.22 — текст функции incr.

//bench/incr_rwlock1.c
1  #include "unpipc.h"
2  #include <synch.h> /* Заголовочный файл для Solaris */
3  void Rw_wrlock(rwlock_t *rwptr);
4  void Rw_unlock(rwlock_t *rwptr);
5  #define MAXNTHREADS 100
6  int nloop;
7  struct {
8   rwlock_t rwlock; /* тип данных Solaris */
9   long counter;
10  } shared; /* инициализация О –> USYNC_THREAD */
11  void *incr(void *);
12 int
13 main(int argc, char **argv)
14 {
15  int i, nthreads;
16  pthread_t tid[MAXNTHREADS];
17  if (argc != 3)
18   err_quit("usage: incr_rwlockl <#loops> <#threads>");
19  nloop = atoi(argv[1]);
20  nthreads = min(atoi(argv[2]), MAXNTHREADS);
21  /* получение блокировки на запись */
22  Rw_wrlock(&shared.rwlock);
23  /* создание всех потоков */
24  Set_concurrency(nthreads);
25  for (i = 0; i < nthreads; i++) {
26   Pthread_create(&tid[i], NULL, incr, NULL);
27  }
28  /* запуск таймера и снятие блокировки */
29  Start_time();
30  Rw_unlock(&shared.rwlock);
31  /* ожидание завершения всех потоков */
32  for (i = 0; i < nthreads; i++) {
33   Pthread_join(tid[i], NULL);
34  }
35  printf("microseconds: %.0f usecn", Stop_time());
36  if (shared.counter != nloop * nthreads)
37   printf("error: counter = %ldn", shared.counter);
38  exit(0);
39 }

//bench/incr_rwlock1.c
40 void *
41 incr(void *arg)
42 {
43  int i;
44  for (i = 0; i < nloop; i++) {
45   Rw_wrlock(&shared.rwlock);
46   shared.counter++;
47   Rw_unlock(&shared.rwlock);
48  }
49  return(NULL);
50 }

Оглавление книги