condition_basic.c

 1// condition_basic.c
 2// 조건 변수 (Condition Variable) 기본 사용법
 3#include <stdio.h>
 4#include <pthread.h>
 5#include <stdbool.h>
 6#include <unistd.h>
 7
 8pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
 9pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
10bool ready = false;
11
12void* waiter(void* arg) {
13    int id = *(int*)arg;
14
15    pthread_mutex_lock(&mutex);
16
17    while (!ready) {  // 조건이 false인 동안 대기
18        printf("[대기자 %d] 조건 대기 중...\n", id);
19        pthread_cond_wait(&cond, &mutex);  // 대기 (뮤텍스 해제됨)
20    }
21    // pthread_cond_wait에서 깨어나면 뮤텍스 다시 획득됨
22
23    printf("[대기자 %d] 조건 만족! 작업 시작\n", id);
24
25    pthread_mutex_unlock(&mutex);
26    return NULL;
27}
28
29void* signaler(void* arg) {
30    (void)arg;
31
32    sleep(2);  // 2초 대기
33
34    pthread_mutex_lock(&mutex);
35    ready = true;
36    printf("[신호자] 조건 설정 완료. 신호 전송!\n");
37    pthread_cond_broadcast(&cond);  // 모든 대기자에게 신호
38    pthread_mutex_unlock(&mutex);
39
40    return NULL;
41}
42
43int main(void) {
44    pthread_t waiters[3];
45    pthread_t sig;
46    int ids[] = {1, 2, 3};
47
48    // 대기 스레드 생성
49    for (int i = 0; i < 3; i++) {
50        pthread_create(&waiters[i], NULL, waiter, &ids[i]);
51    }
52
53    // 신호 스레드 생성
54    pthread_create(&sig, NULL, signaler, NULL);
55
56    // 대기
57    for (int i = 0; i < 3; i++) {
58        pthread_join(waiters[i], NULL);
59    }
60    pthread_join(sig, NULL);
61
62    pthread_mutex_destroy(&mutex);
63    pthread_cond_destroy(&cond);
64
65    return 0;
66}