当前位置: C语言 -- 标准库 -- <threads.h> -- mtx_trylock

mtx_trylock函数


概要:
#include <threads.h>
int mtx_trylock(mtx_t *mtx);

描述:

该函数试图加锁参数mtx指向的互斥。如果参数mtx指向的互斥已经被加锁,函数返回,并且不会阻塞调用线程。如果成功加锁互斥,对于同一互斥先前mtx_unlock函数的调用与该函数的操作同步。


参数:
mtx_t *mtx

指向将被加锁的互斥的指针。


返回值:

如果成功加锁互斥,函数返回thrd_success;如果请求的资源已经在使用,函数返回thrd_busy;如果请求无法得到满足,函数返回thrd_error。加锁未使用资源时mtx_trylock函数可能会出现伪失败(spuriously fail),这种情况下函数返回thrd_busy


范例:
1 
2 
3 
4 
5 
6 
7 
8 
9 
10 
11 
12 
13 
14 
15 
16 
17 
18 
19 
20 
21 
22 
23 
24 
25 
26 
27 
28 
29 
30 
31 
32 
33 
34 
35 
36 
37 
38 
39 
40 
41 
42 
43 
44 
45 
46 
47 
48 
49 
50 
51 
52 
53 
54 
55 
56 
57 
58 
59 
60 
61 
62 
63 
64 
65 
66 
67 
68 
69 
70 
71 
72 
73 
74 
75 
76 
77 
78 
79 
80 
81 
82 
/*函数mtx_trylock范例*/

#ifdef __STDC_NO_THREADS__
#error "Implementation does not support multi-threads."
#endif

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

mtx_t mutex;

/*在新线程中执行的函数一。*/
int funcOne(void *arg)
{
    thrd_sleep(&(struct timespec){*((int *)arg), 0}, NULL);
    
    switch(mtx_trylock(&mutex))
    {
    case thrd_busy:
        puts("The resource requested is already in use.");
        thrd_exit(thrd_busy);
    case thrd_error:
        puts("The request could not be honored.");
        thrd_exit(thrd_error);
    default:
        puts("The function has successfully locked the mutex.");
        break;
    }
    
    /*其它代码。*/
    
    mtx_unlock(&mutex);

    thrd_exit(0);
}

/*在新线程中执行的函数二。*/
int funcTwo(void *arg)
{
    mtx_lock(&mutex);
    thrd_sleep(&(struct timespec){*((int *)arg)+5, 0}, NULL);
    mtx_unlock(&mutex);
    
    thrd_exit(0);
}

int main(void)
{
    thrd_t threadOne, threadTwo;
    int duration = 5;

    /*初始化互斥。*/
    if(mtx_init(&mutex, mtx_plain) != thrd_success)
    {
        perror("mtx_init");
        exit(EXIT_FAILURE);
    }

    /*创建线程。*/
    if(thrd_create(&threadOne, funcOne, &duration) != thrd_success)
    {
        perror("thrd_create");
        exit(EXIT_FAILURE);
    }
    
    if(thrd_create(&threadTwo, funcTwo, &duration) != thrd_success)
    {
        perror("thrd_create");
        exit(EXIT_FAILURE);
    }
    
    /*连接线程。*/
    thrd_join(threadOne, NULL);
    thrd_join(threadTwo, NULL);

    /*销毁互斥。*/
    mtx_destroy(&mutex);

    return 0;
}


输出:

The resource requested is already in use.

注:使用Pelles C编译。

在这个例子中创建了两个新线程,通过thrd_sleep(&(struct timespec){*((int *)arg), 0}, NULL);语句使第一个线程暂停5秒;第二个线程加锁互斥,当第一个线程中mtx_trylock函数尝试加锁互斥时,函数返回thrd_busy


相关内容:
mtx_lock 加锁互斥的函数。
mtx_timedlock 支持超时加锁互斥的函数。
mtx_destroy 销毁互斥的函数。
mtx_init 创建互斥的函数。
mtx_unlock 解锁互斥的函数。