Implementing a FIFO mutex in pthreads

by

You can implement a fair queuing system where each thread is added to a queue when it blocks, and the first thread on the queue always gets the resource when it becomes available. Such a “fair” ticket lock built on pthreads primitives might look like this:

#include <pthread.h>

typedef struct ticket_lock {
    pthread_cond_t cond;
    pthread_mutex_t mutex;
    unsigned long queue_head, queue_tail;
} ticket_lock_t;

#define TICKET_LOCK_INITIALIZER { PTHREAD_COND_INITIALIZER, PTHREAD_MUTEX_INITIALIZER }

void ticket_lock(ticket_lock_t *ticket)
{
    unsigned long queue_me;

    pthread_mutex_lock(&ticket->mutex);
    queue_me = ticket->queue_tail++;
    while (queue_me != ticket->queue_head)
    {
        pthread_cond_wait(&ticket->cond, &ticket->mutex);
    }
    pthread_mutex_unlock(&ticket->mutex);
}

void ticket_unlock(ticket_lock_t *ticket)
{
    pthread_mutex_lock(&ticket->mutex);
    ticket->queue_head++;
    pthread_cond_broadcast(&ticket->cond);
    pthread_mutex_unlock(&ticket->mutex);
}

More Related Contents:

  1. Why do pthreads’ condition variable functions require a mutex?
  2. Does pthread_cond_wait(&cond_t, &mutex); unlock and then lock the mutex?
  3. Is it possible to determine the thread holding a mutex?
  4. Share condition variable & mutex between processes: does mutex have to locked before?
  5. Check to see if a pthread mutex is locked or unlocked (After a thread has locked itself)
  6. PTHREAD_MUTEX_INITIALIZER vs pthread_mutex_init ( &mutex, param)
  7. Pthreads in C. Simple example doesn’t work [closed]
  8. Still Reachable Leak detected by Valgrind
  9. POSIX threads and signals
  10. Multiple arguments to function called by pthread_create()?
  11. Wake up thread blocked on accept() call
  12. Undefined reference to ‘pthread_create’ — linker command option order (libraries before/after object files?) [duplicate]
  13. POSIX API call to list all the pthreads running in a process
  14. How to return a value from pthread threads in C?
  15. Kill Thread in Pthread Library
  16. How to set the name of a thread in Linux pthreads?
  17. pthread_create and passing an integer as the last argument
  18. Is it OK to call pthread_exit from main?
  19. Interprocess mutex with pthreads
  20. How do you query a pthread to see if it is still running?
  21. Using C/Pthreads: do shared variables need to be volatile?
  22. How does a mutex lock and unlock functions prevents CPU reordering?
  23. When to use pthread condition variables?
  24. Is accept() thread-safe?
  25. Linux/POSIX equivalent for Win32’s CreateEvent, SetEvent, WaitForSingleObject
  26. Do pthread mutexes work across threads if in shared memory?
  27. How to set up pthreads on windows?
  28. Pthreads vs. OpenMP
  29. Program received signal SIGPIPE, Broken pipe
  30. pthread execution on linux

Leave a Comment