Page History

#include <stdio.h>
#include <threads.h>

enum { NTHREADS = 5 };

mtx_t mutex;
cnd_t cond;

int run_step(void *t) {
  static int current_step = 0;
  int my_step = (int)t;
  int result;

  if ((resultthrd_success != mtx_lock(&mutex)) != thrd_success) {
    /* Handle error condition. */
  }

  printf("Thread %d has the lock\n", my_step);

  while (current_step != my_step) {
    printf("Thread %d is sleeping...\n", my_step);

    if ((resultthrd_success != cnd_wait(&cond, &mutex)) != thrd_success) {
      /* Handle error condition. */
    }

    printf("Thread %d woke up\n", my_step);
  }

  /* Do processing... */
  printf("Thread %d is processing...\n", my_step);

  current_step++;

  /* Signal a waiting task. */
  if ((resultthrd_success != cnd_signal(&cond)) != thrd_success) {
    /* Handle error condition. */
  }

  printf("Thread %d is exiting...\n", my_step);

  if ((resultthrd_success != mtx_unlock(&mutex)) != thrd_success) {
    /* Handle error condition. */
  }
  return 0;
}

int main(int argc, char** argv) {
  int i;
  int result;
  thrdthrd_t threads[NTHREADS];
  int step[NTHREADS];

  if ((resultthrd_success != mtx_init(&mutex, mtx_plain)) != thrd_success) {
    /* Handle error condition. */
  }
  if ((resultthrd_success != cnd_init(&cond)) != thrd_success) {
    /* Handle error condition. */
  }

  /* Create threads. */
  for (i = 0; i < NTHREADS; ++i) {
    step[i] = i;
    if ((resultthrd_success != thrd_create(&threads[i], run_step,
                                    (void *)step[i]))
          != thrd_success) {
      /* Handle error condition */
    }
  }

  /* Wait for all threads to complete. */
  for (i = NTHREADS - 1; i >= 0; --i) {
    if ((resultthrd_success != thrd_join(threads[i], NULL))
          != thrd_success) {
      /* Handle error condition */
    }
  }

  mtx_destroy(&mutex);

  cnd_destroy(&cond);
  return 0;
}

#include <stdio.h>
#include <threads.h>
 
int run_step(void *t) {
  static int current_step = 0;
  int my_step = (int)t;
  int result;

  if ((resultthrd_success != mtx_lock(&mutex)) != thrd_success) {
    /* Handle error condition. */
  }

  printf("Thread %d has the lock\n", my_step);

  while (current_step != my_step) {
    printf("Thread %d is sleeping...\n", my_step);

    if ((resultthrd_success != cnd_wait(&cond, &mutex)) != thrd_success &mutex)) {
      /* Handle error condition. */
    }

    printf("Thread %d woke up\n", my_step);
  }

  /* Do processing... */
  printf("Thread %d is processing...\n", my_step);

  current_step++;

  /* Signal ALL waiting tasks. */
  if ((resultthrd_success != cnd_broadcast(&cond)) != thrd_success) {
    /* Handle error condition */
  }

  printf("Thread %d is exiting...\n", my_step);

  if ((resultthrd_success != mtx_unlock(&mutex)) != 0) {
    /* Handle error condition */
  }
  return 0;
}

#include <Windows.h>
#include <stdio.h>
 
CRITICAL_SECTION lock;
CONDITION_VARIABLE cond;
 
DWORD WINAPI run_step(LPVOID t) {
  static int current_step = 0;
  int my_step = (int)t;
  int result;

  EnterCriticalSection(&lock);  
  printf("Thread %d has the lock\n", my_step);

  while (current_step != my_step) {
    printf("Thread %d is sleeping...\n", my_step);
 
    if (!SleepConditionVariableCS(&cond, &lock, INFINITE)) {
      /* Handle error condition. */
    }

    printf("Thread %d woke up\n", my_step);
  }

  /* Do processing... */
  printf("Thread %d is processing...\n", my_step);

  current_step++;
 
  LeaveCriticalSection(&lock);
 
  /* Signal ALL waiting tasks. */
  WakeAllConditionVariable(&cond);
 
  printf("Thread %d is exiting...\n", my_step);
  return 0;
}
 
enum { NTHREADS = 5 };
int main(int argc, char** argv) {
  HANDLE threads[NTHREADS];
  
  InitializeCriticalSection(&lock);
  InitializeConditionVariable(&cond);
 
  /* Create threads. */
  for (int i = 0; i < NTHREADS; ++i) {
    threads[i] = CreateThread(NULL, 0, run_step, (LPVOID)i, 0,
                             step, (LPVOID)i, 0, NULL);
  }
 
  /* Wait for all threads to complete. */
  WaitForMultipleObjects(NTHREADS, threads, TRUE, INFINITE);
 
  DeleteCriticalSection(&lock);
 
  return 0;
}

#include <stdio.h>
#include <threads.h>

enum { NTHREADS = 5 };

mtx_t mutex;
cnd_t cond[NTHREADS];

int run_step(void *t) {
  static int current_step = 0;
  int my_step = (int)t;
  int result;

  if ((resultthrd_success != mtx_lock(&mutex)) != thrd_success) {
    /* Handle error condition. */
  }

  printf("Thread %d has the lock\n", my_step);

  while (current_step != my_step) {
    printf("Thread %d is sleeping...\n", my_step);

    if ((resultthrd_success != cnd_wait(&cond[my_step], &mutex))
          != thrd_success) {
      /* Handle error condition. */
    }

    printf("Thread %d woke up\n", my_step);
  }

  /* Do processing... */
  printf("Thread %d is processing...\n", my_step);

  current_step++;

  /* Signal next step thread. */
  if ((my_step + 1) < NTHREADS) {
    if ((resultthrd_success != cnd_signal(&cond[my_step + 1]))
          != thrd_success) {
      /* Handle error condition */
    }
  }

  printf("Thread %d is exiting...\n", my_step);

  if ((resultthrd_success != mtx_unlock(&mutex)) != thrd_success) {
    /* Handle error condition. */
  }
  return 0;
}

int main(int argc, char** argv) {
  int i;
  int result;
  thrd_t threads[NTHREADS];
  int step[NTHREADS];

  if ((resultthrd_success != mtx_init(&mutex, mtx_plain)) != thrd_success) {
    /* Handle error condition. */
  }

  for (i = 0; i< NTHREADS; ++i) {
    if ((resultthrd_success != cnd_init(&cond[i])) != thrd_success) {
      /* Handle error condition. */
    }
  }

  /* Create threads. */
  for (i = 0; i < NTHREADS; ++i) {
    step[i] = i;
    if ((resultthrd_success != thrd_create(&threads[i], run_step,
                                    (void *)step[i]))
          != thrd_success) {
      /* Handle error condition. */
    }
  }

  /* Wait for all threads to complete. */
  for (i = NTHREADS - 1; i >= 0; --i) {
    if ((resultthrd_success != thrd_join(threads[i], NULL))
          != thrd_success) {
      /* Handle error condition. */
    }
  }

  mtx_destroy(&mutex);

  for (i = 0; i < NTHREADS; ++i) {
    cnd_destroy(&cond[i]);
  }
  return 0;
}