UNIX: разработка сетевых приложений

  4 void *doit(void*);

  5 int
  6 main(int argc, char **argv)
  7 {
  8 pthread_t tidA, tidB;

  9 Pthread_create(&tidA, NULL, &doit, NULL);
 10 Pthread_create(&tidB, NULL, &doit, NULL);

 11 /* ожидание завершения обоих потоков */
 12 Pthread_join(tidA, NULL);
 13 Pthread_join(tidB, NULL);

 14 exit(0);
 15 }

 16 void*
 17 doit(void *vptr)
 18 {
 19 int i, val;

20 /* Каждый поток получает, выводит и увеличивает на
 21 * единицу переменную counter NLOOP раз. Значение
 22 * переменной должно увеличиваться монотонно.
 23 */

 24 for (i = 0; i < NLOOP; i++) {
 25 val = counter;
 26 printf("%d: %d\n", pthread_self, val + 1);
 27 counter = val + 1;
 28 }

 29 return (NULL);
 30 }

Обратите внимание на то, что в первый раз ошибка происходит при переключении системы с выполнения потока номер 4 на выполнение потока номер 5: каждый поток в итоге записывает значение 518. Это происходит множество раз на протяжении 10 000 строк вывода.

Недетерминированная природа ошибок такого типа также будет очевидна, если мы запустим программу несколько раз: каждый раз результат выполнения программы будет отличаться от предыдущего. Также, если мы переадресуем вывод результатов в файл на диске, эта ошибка иногда не будет возникать, так как программа станет работать быстрее, что приведет к уменьшению вероятности переключения системы между потоками. Наибольшее количество ошибок возникнет в случае, если программа будет работать интерактивно, записывая результат на медленный терминал, но при этом также сохраняя результат в файл при помощи программы Unix script(которая описана в главе 19 книги [110]).

Только что описанная проблема, возникающая, когда несколько потоков изменяют значение одной переменной, является самой простой из проблем параллельного программирования. Для решения этой проблемы используются так называемые взаимные исключения( mutex — mutual exclusion), с помощью которых контролируется доступ к переменной. В терминах Pthreads взаимное исключение — это переменная типа pthread_mutex_t, которая может быть заблокирована и разблокирована с помощью следующих двух функций:

 #include <pthread.h>

 int pthread_mutex_lock(pthread_mutex_t * mptr);
 int pthread_mutex_unlock(pthread_mutex_t * mptr);
  Обе функции возвращают: 0 в случае успешного выполнения, положительное значение Exxx в случае ошибки

Если некоторый поток попытается блокировать взаимное исключение, которое уже блокировано каким-либо другим потоком (то есть принадлежит ему в данный момент времени), этот поток окажется заблокированным до освобождения взаимного исключения.

Если переменная-исключение размещена в памяти статически, следует инициализировать ее константой PTHREAD_MUTEX_INITIALIZER. В разделе 30.8 мы увидим, что если мы размещаем исключение в совместно используемой (разделяемой) памяти, мы должны инициализировать его во время выполнения программы путем вызова функции pthread_mutex_init.

ПРИМЕЧАНИЕ

Некоторые системы (например, Solaris) определяют константу PTHREAD_MUTEX_INITIALIZER как 0. Если данная инициализация будет опущена, это ни на что не повлияет, так как статически размещаемые переменные все равно автоматически инициализируются нулем. Но для других систем такой гарантии дать нельзя — например, в Digital Unix константа инициализации ненулевая.

В листинге 26.12 приведена исправленная версия листинга 26.11, в которой используется одно взаимное исключение для блокирования счетчика при работе с двумя потоками.

Листинг 26.12. Исправленная версия листинга 26.11, использующая взаимное исключение для защиты совместно используемой переменной

 //threads/examplе01.с
  1 #include "unpthread.h"

  2 #define NLOOP 5000

  3 int counter; /* увеличивается потоками */
  4 pthread_mutex_t counter_mutex = PTHREAD_MUTEX_INITIALIZER;

  5 void *doit(void*);

  6 int
  7 main(int argc, char **argv)
  8 {
  9 pthread_t tidA, tidB;

 10 Pthread_create(&tidA, NULL, &doit, NULL);
 11 Pthread_create(&tidB, NULL, &doit, NULL);

 12 /* ожидание завершения обоих потоков */
 13 Pthread_join(tidA, NULL);
 14 Pthread_join(tidB, NULL);

 15 exit(0);
 16 }

 17 void*
 18 doit(void *vptr)
 19 {
 20 int i, val;

 21 /*
 22 * Каждый поток считывает, выводит и увеличивает счетчик NLOOP раз.
 23 * Значение счетчика должно возрастать монотонно.
 24 */

 25 for (i = 0; i < NLOOP; i++) {
 26 Pthread_mutex_lock(&counter_mutex);

 27 val = counter;
 28 printf(%d: %d\n", pthread_self, val + 1);
 29 counter = val + 1;

 30 Pthread_mutex_unlock(&counter_mutex);