POSIX 互斥锁

95 阅读 0 评论 63 点赞

我是靠谱客的博主俏皮菠萝，最近开发中收集的这篇文章主要介绍POSIX 互斥锁，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

转载地址：http://blog.csdn.net/wypblog/article/details/7264315

Linux下为了多线程同步，通常用到锁的概念。

POSIX下抽象了一个锁类型的结构：ptread_mutex_t。通过对该结构的操作，来判断资源是否可以访问。顾名思义，加锁(lock)后，别人就无法打开，只有当锁没有关闭(unlock)的时候才能访问资源。
它主要用如下5个函数进行操作。
1：pthread_mutex_init( pthread_mutex_t * mutex,const pthread_mutexattr_t *attr);
初始化锁变量mutex。attr为锁属性，NULL值为默认属性。
2：pthread_mutex_lock( pthread_mutex_t *mutex);加锁
3：pthread_mutex_tylock( pthread_mutex_t *mutex);加锁，但是与2不一样的是当锁已经在使用的时候，返回为EBUSY，而不是挂起等待。
4：pthread_mutex_unlock( pthread_mutex_t *mutex);释放锁
5：pthread_mutex_destroy( pthread_mutex_t *mutex );使用完后释放

下面这个例子首先是创建了两个线程，线程1从0加到49，线程2从50加到99，如果加了锁，打印的结果就是按照先后顺序正确打印，结果如下：

add1: sum is 1225
add2: sum is 4950

如果我们把线程里面加锁的部分去掉的话，两个线程就会交叉运行，最后的结果就不一定了。

#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <pthread.h>
typedef struct ct_sum
{
int sum;
pthread_mutex_t lock;
}ct_sum;
void* add1(void* cnt)
{
int i;
pthread_mutex_lock(&(((ct_sum*)cnt)->lock));
for(i = 0; i < 50; i++)
{
((ct_sum*)cnt)->sum += i;
usleep(1000);
}
printf("%s: sum is %dn", __func__, ((ct_sum*)cnt)->sum);
pthread_mutex_unlock(&(((ct_sum*)cnt)->lock));
pthread_exit(NULL);
}
void* add2(void* cnt)
{
int i;
pthread_mutex_lock(&(((ct_sum*)cnt)->lock));
for(i = 50; i < 100; i++)
{
((ct_sum*)cnt)->sum += i;
usleep(1000);
}
printf("%s: sum is %dn", __func__, ((ct_sum*)cnt)->sum);
pthread_mutex_unlock(&(((ct_sum*)cnt)->lock));
pthread_exit(NULL);
}
int main(void)
{
int i;
pthread_t ptid_1, ptid_2;
int sum = 0;
ct_sum cnt;
pthread_mutex_init(&(cnt.lock), NULL);
cnt.sum = 0;
pthread_create(&ptid_1, NULL, add1, &cnt);
pthread_create(&ptid_2, NULL, add2, &cnt);
pthread_join(ptid_1, NULL);
pthread_join(ptid_2, NULL);
pthread_mutex_destroy(&(cnt.lock));
return 0;
}
注：线程里面每个循环加一个延时，就是为了能够比较明显的看到加锁与不加锁的区别。