Обобщённая задача взаимного исключения

#include <iostream>
#include <pthread.h>
#include <linux/futex.h>
#include <assert.h>
#include <unistd.h>
 
using namespace std;
 
pthread_mutex_t mutex;
 
const int N = 10;
int b[N], c[N];
int iqueue;
int n = 0;
void* process(void* arg)
{
int value;
value = *((int*) arg);
int j, k;
Ai: b[value] = 0;
Li: if (iqueue != value)
{
c[value] = 1;
k = iqueue;
if (b[k] = 1)
iqueue = value;
goto Li;
}
c[value] = 0;
for (j = 1; j <= N; j++)
{
if ((j != value) && (c[value] = 0))
{
goto Li;
}
pthread_mutex_lock(&mutex);
iqueue = 0;
c[value] = 1;
b[value] = 1;
pthread_mutex_unlock(&mutex);
goto Ai;
}
return NULL;
}
void* perform_work(void* arg)
{
int value;
value = *((int*) arg);
cout « "Thread " « value « endl;
return NULL;
}
int main()
{
mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_t threads[N];
int thread_args[N];
int result_code;
for(iqueue = 0; iqueue < N; iqueue++)
{
b[iqueue] = 1;
c[iqueue] = 1;
}
iqueue = 0;
 
for (int i = 1; i <= N; ++i)
{
thread_args[i] = i;
cout « "Creating thread " « i « endl;
pthread_create(&threads[i], NULL, process, &thread_args[i]);
}
for (int i = 1; i <= N; ++i)
{
pthread_join(threads[i], NULL);
}
pthread_mutex_destroy(&mutex);
return 0;
}