Lock a mutex
#include <pthread.h> int pthread_mutex_lock( pthread_mutex_t* mutex );
libc
Use the -l c option to qcc to link against this library. This library is usually included automatically.
The pthread_mutex_lock() function locks the mutex object referenced by mutex. If the mutex is already locked, then the calling thread blocks until it has acquired the mutex. When the function returns, the mutex object is locked and owned by the calling thread.
This function's behavior when you try to lock a mutex that you already own depends on the type of the mutex. For more information, see the entry for pthread_mutexattr_settype().
By default, if a thread with a higher priority than the mutex owner attempts to lock a mutex, then the effective priority of the current owner is increased to that of the higher-priority blocked thread waiting for the mutex. The owner returns to its real priority when it unlocks the mutex. For more information, see “Mutexes: mutual exclusion locks” in the QNX Neutrino Microkernel chapter of the System Architecture guide.
If the mutex is recursive, you must call pthread_mutex_unlock() for each corresponding call to lock the mutex.
If a signal is delivered to a thread that's waiting for a mutex, the thread resumes waiting for the mutex on returning from the signal handler.
If, before initializing the mutex, you've called pthread_mutexattr_setwakeup_np() to enable wake-ups, you can later call pthread_mutex_wakeup_np(), to wake up any threads that are blocked on the mutex. The “np” in these functions' names stands for “non-POSIX.”
This example shows how you can use a mutex to synchronize access to a shared variable. In this example, function1() and function2() both attempt to access and modify the global variable count. Either thread could be interrupted between modifying count and assigning its value to the local tmp variable. Locking mutex prevents this from happening; if one thread has mutex locked, the other thread waits until it's unlocked, before continuing.
#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; }
Safety: | |
---|---|
Cancellation point | No |
Interrupt handler | No |
Signal handler | Yes |
Thread | Yes |
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()
“Mutexes: mutual exclusion locks” in the QNX Neutrino Microkernel chapter of the System Architecture guide
Processes and Threads chapter of Getting Started with QNX Neutrino