# C 语言标准库函数 mtx_timedlock

/*********************************************
 * @brief 锁定互斥量，支持超时
 * @param mutex 要加锁的互斥量 ID
 * @param time_point 超时的时间点
 * @return 是否成功
 ********************************************/
int mtx_timedlock(mtx_t* mutex, const struct timespec* restrict time_point);

/*********************************************
 * @brief 生成超时的绝对时间点
 * @param[out] time_point 返回绝对时间点
 * @param sec 持续的秒数
 ********************************************/
void generate_timeout(struct timespec* time_point, int sec)
{
    timespec_get(time_point, TIME_UTC); // 获取基于 TIME_UTC 的当前时间
    time_point->tv_sec += sec; // 增加 sec 秒
}

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

// 线程函数
int func(void* data)
{
    mtx_t* mutex = (mtx_t*)data; // 通过参数传递互斥量

    // 计算绝对时间点
    struct timespec time_point;
    timespec_get(&time_point, TIME_UTC); // 获取基于 TIME_UTC 的当前时间
    time_point.tv_sec += 5; // 增加 5 秒

    printf("开始时间: %s", ctime(&(time_t){time(NULL)}));

    // 加锁
    if (mtx_timedlock(mutex, &time_point) == thrd_success)
    {
        printf("加锁成功\n");
    }
    else
    {
        printf("加锁失败\n");
    }

    printf("结束时间: %s", ctime(&(time_t){time(NULL)}));
    
    return 0;
}

int main(void)
{
    // 创建支持超时的互斥量
    mtx_t mutex;
    mtx_init(&mutex, mtx_timed); 

    // 加锁
    mtx_lock(&mutex);

    // 创建线程
    thrd_t th;
    thrd_create(&th, func, &mutex); // 通过参数传递数据和互斥量

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

    // 加锁
    mtx_unlock(&mutex);

    // 清除互斥量
    mtx_destroy(&mutex);
    
    return 0;
}

开始时间: Sun Aug 24 13:54:46 2025
加锁失败
结束时间: Sun Aug 24 13:54:51 2025