# C 语言标准库函数 cnd_init

/*********************************************
 * @brief 创建条件变量
 * @param[out] cond 返回条件变量 ID
 * @return 是否成功
 ********************************************/
int cnd_init(cnd_t* cond);

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

// 全局变量
mtx_t mutex;        // 互斥量
cnd_t cond;         // 条件变量
int turn = 1;       // 1 表示线程 1 打印，2 表示线程 2 打印 

// 线程函数1
int func1(void* data)
{
    // 与线程 2 交替打印
    for (int i = 0; i < 10; i++)
    {
        mtx_lock(&mutex);               // 锁定互斥量
        while (turn != 1)
        {
            cnd_wait(&cond, &mutex);    // 等待信号
        }
        printf("线程1: %d\n", i);
        turn = 2;
        cnd_signal(&cond);              // 发送信号，唤醒线程 2
        mtx_unlock(&mutex);             // 解锁互斥量
    }
    
    return 0;
}

// 线程函数2
int func2(void* data)
{
    // 与线程 1 交替打印
    for (int i = 0; i < 10; i++)
    {
        mtx_lock(&mutex);               // 锁定互斥量
        while (turn != 2)
        {
            cnd_wait(&cond, &mutex);    // 等待信号
        }
        printf("线程2: %d\n", i);
        turn = 1;
        cnd_signal(&cond);              // 发送信号，唤醒线程 1
        mtx_unlock(&mutex);             // 解锁互斥量
    }
    
    return 0;
}

int main(void)
{
    mtx_init(&mutex, mtx_plain);    // 创建互斥量
    cnd_init(&cond);                // 创建条件变量

    // 创建线程
    thrd_t th1, th2;
    thrd_create(&th1, func1, NULL);
    thrd_create(&th2, func2, NULL);

    // 等待线程结束
    thrd_join(th1, NULL);
    thrd_join(th2, NULL);

    // 清除互斥量和条件变量
    mtx_destroy(&mutex);
    cnd_destroy(&cond);
    
    return 0;
}

线程1: 0
线程2: 0
线程1: 1
线程2: 1
线程1: 2
线程2: 2
线程1: 3
线程2: 3
线程1: 4
线程2: 4
线程1: 5
线程2: 5
线程1: 6
线程2: 6
线程1: 7
线程2: 7
线程1: 8
线程2: 8
线程1: 9
线程2: 9

while (turn != 1)
{
    // 一直检查，CPU空转，浪费资源
}