на главную | войти | регистрация | DMCA | контакты | справка | donate |      

A B C D E F G H I J K L M N O P Q R S T U V W X Y Z
А Б В Г Д Е Ж З И Й К Л М Н О П Р С Т У Ф Х Ц Ч Ш Щ Э Ю Я


моя полка | жанры | рекомендуем | рейтинг книг | рейтинг авторов | впечатления | новое | форум | сборники | читалки | авторам | добавить



Листинг А.21. Функция main для блокировок чтения-записи

//bench/incr_rwlock1.c

1  #include "unpipc.h"

2  #include /* Заголовочный файл для 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 usec\n", Stop_time());

36  if (shared.counter != nloop * nthreads)

37   printf("error: counter = %ld\n", shared.counter);

38  exit(0);

39 }


Блокировки чтения-записи | UNIX: взаимодействие процессов | Листинг А.22. Увеличение общего счетчика с использованием блокировок чтения-записи