pthread_mutex_lock()

Заблокировать мьютекс

Прототип:

#include <pthread.h>
int pthread_mutex_lock( pthread_mutex_t *mutex );

Аргументы:

mutex
Указатель на объект pthread_mutex_t, который необходимо заблокировать.

Библиотека:

libc

Описание:

Функция pthread_mutex_lock() блокирует мьютекс mutex. Если мьютекс уже заблокирован, то вызывающий поток блокируется до тех пор, пока он не захватит мьютекс. По возвращении из функции, объект мьютекса блокируется и принадлежит вызывающему потоку.

Поведение этой функции при попытке заблокировать уже принадлежащий вам мьютекс зависит от типа мьютекса. Для получения дополнительной информации см. pthread_mutexattr_settype().

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

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

Если сигнал доставлен потоку, ожидающему мьютекс, поток возобновляет ожидание мьютекса по возвращении из обработчика сигнала.

Если перед инициализацией мьютекса была вызвана функция pthread_mutexattr_setwakeup_np() для включения "пробуждения", можно позже вызвать pthread_mutex_wakeup_np(), чтобы "разбудить" любые потоки, заблокированные на мьютексе. Постфикс «np» в именах этих функций означает «не-POSIX».

Возвращаемое значение:

EOK
Успешное завершение.
EAGAIN
Недостаточно системных ресурсов для блокировки мьютекса.
EDEADLK
Вызывающий поток уже владеет mutex, а мьютекс не допускает рекурсивного поведения.
EFAULT
Произошла ошибка, когда ядро попыталось получить доступ к предоставленным буферам.
EINTR
(расширение ЗОСРВ «Нейтрино») Поток был разблокирован вызовом pthread_mutex_wakeup_np().
EINVAL
Некорректный мьютекс mutex.
ETIMEDOUT
Тайм-аут ядра разблокировал вызов.

Примеры:

В данном примере показано, как можно использовать мьютекс для синхронизации доступа к общей переменной. В этом примере function1() и function2() пытаются получить доступ и изменить глобальную переменную count. Любой поток может быть прерван между изменением счетчика и присвоением его значения локальной переменной tmp. Блокировка mutex предотвращает это; если один поток заблокировал mutex, другой поток ждет, пока он не будет разблокирован, прежде чем продолжить.

#include <stdio.h>
#include <pthread.h>
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
int count = 0;
void * function1( void *arg )
{
int tmp = 0;
while ( 1 )
{
pthread_mutex_lock( &mutex );
tmp = count++;
pthread_mutex_unlock( &mutex );
printf( "Count is %d\n", tmp );
/* snooze for 1 second */
sleep( 1 );
}
return (0);
}
void * function2( void *arg )
{
int tmp = 0;
while ( 1 )
{
pthread_mutex_lock( &mutex );
tmp = count--;
pthread_mutex_unlock( &mutex );
printf( "** Count is %d\n", tmp );
/* snooze for 2 seconds */
sleep( 2 );
}
return (0);
}
int main( void )
{
pthread_create( NULL, NULL, &function1, NULL );
pthread_create( NULL, NULL, &function2, NULL );
/* Let the threads run for 60 seconds. */
sleep( 60 );
return (0);
}

Классификация:

POSIX 1003.1 THR

Точка остановки потока
Нет
Обработчик прерываний
Нет
Обработчик сигналов
Да
В потоке
Да

Тематические ссылки:

pthread_mutex_init(), pthread_mutex_timedlock(), pthread_mutex_trylock(), pthread_mutex_unlock(), pthread_mutex_wakeup_np(), pthread_mutexattr_setrecursive(), pthread_mutexattr_settype(), pthread_mutexattr_setwakeup_np() SyncMutexLock()




Предыдущий раздел: Описание API системной библиотеки