| /******************************************************** |
| * An example source module to accompany... |
| * |
| * "Using POSIX Threads: Programming with Pthreads" |
| * by Brad nichols, Dick Buttlar, Jackie Farrell |
| * O'Reilly & Associates, Inc. |
| * |
| ******************************************************** |
| * once_exam.c |
| * |
| * An example of using the pthreads_once() call to execute an |
| * initialization procedure. |
| * |
| * A program spawns multiple threads and each one tries to |
| * execute the routine welcome() using the once call. Only |
| * the first thread into the once routine will actually |
| * execute welcome(). |
| * |
| * The program's main thread synchronizes its exit with the |
| * exit of the threads using the pthread_join() operation. |
| * |
| */ |
| |
| #include <stdlib.h> |
| #include <stdio.h> |
| #include <unistd.h> |
| #include <sys/types.h> |
| |
| #include <pthread.h> |
| |
| #define NUM_THREADS 10 |
| |
| static pthread_once_t welcome_once_block = PTHREAD_ONCE_INIT; |
| |
| void welcome(void) |
| { |
| printf("welcome: Welcome\n"); |
| } |
| |
| void *identify_yourself(void *arg) |
| { |
| int rtn; |
| |
| if ((rtn = pthread_once(&welcome_once_block, |
| welcome)) != 0) { |
| fprintf(stderr, "pthread_once failed with %d",rtn); |
| pthread_exit((void *)NULL); |
| } |
| printf("identify_yourself: Hi, I'm a thread\n"); |
| return(NULL); |
| } |
| |
| extern int |
| main(void) |
| { |
| int *id_arg, thread_num, rtn; |
| pthread_t threads[NUM_THREADS]; |
| |
| id_arg = (int *)malloc(NUM_THREADS*sizeof(int)); |
| |
| for (thread_num = 0; thread_num < NUM_THREADS; (thread_num)++) { |
| |
| id_arg[thread_num] = thread_num; |
| |
| if (( rtn = pthread_create(&threads[thread_num], |
| NULL, |
| identify_yourself, |
| (void *) &(id_arg[thread_num]))) |
| != 0) { |
| fprintf(stderr, "pthread_create failed with %d",rtn); |
| exit(1); |
| } |
| } |
| |
| for (thread_num = 0; thread_num < NUM_THREADS; thread_num++) { |
| pthread_join(threads[thread_num], NULL); |
| //printf("main: joined to thread %d\n", thread_num); |
| } |
| printf("main: Goodbye\n"); |
| return 0; |
| } |