Chinaunix首页 | 论坛 | 博客
  • 博客访问: 325671
  • 博文数量: 78
  • 博客积分: 2536
  • 博客等级: 少校
  • 技术积分: 600
  • 用 户 组: 普通用户
  • 注册时间: 2008-04-29 01:50
文章分类

全部博文(78)

文章存档

2011年(1)

2010年(17)

2009年(52)

2008年(8)

我的朋友

分类: LINUX

2010-04-10 17:38:20

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);使用完后释放

下面经典例子为创建两个线程对sum从1加到100。前面第一个线程从1-49,后面从50-100。主线程读取最后的加值。为了防止资源竞争,用了pthread_mutex_t 锁操作。
#include
#include
#include
#include
typedef struct ct_sum
{ int sum;
  pthread_mutex_t lock;
}ct_sum;
void * add1(void * cnt)
{    
  
    pthread_mutex_lock(&(((ct_sum*)cnt)->lock));
    int i;
        for( i=0;i<50;i++)
        {(*(ct_sum*)cnt).sum+=i;
       
        }
    pthread_mutex_unlock(&(((ct_sum*)cnt)->lock));
    pthread_exit(NULL);
    return 0;
}
void * add2(void *cnt)
{    
    int i;
    cnt= (ct_sum*)cnt;
    pthread_mutex_lock(&(((ct_sum*)cnt)->lock));
    for( i=50;i<101;i++)
    {    (*(ct_sum*)cnt).sum+=i;
       
    }
    pthread_mutex_unlock(&(((ct_sum*)cnt)->lock));
    pthread_exit(NULL);
    return 0;
}


int main(void)
{ int i;
  pthread_t ptid1,ptid2;
  int sum=0;
  ct_sum cnt;
  pthread_mutex_init(&(cnt.lock),NULL);
  cnt.sum=0;

  pthread_create(&ptid1,NULL,add1,&cnt);
pthread_create(&ptid2,NULL,add2,&cnt);
 
 pthread_mutex_lock(&(cnt.lock));
 printf("sum %d\n",cnt.sum);
 pthread_mutex_unlock(&(cnt.lock));

 pthread_join(ptid1,NULL);
 pthread_join(ptid2,NULL);
  pthread_mutex_destroy(&(cnt.lock));
  return 0;
}
阅读(10180) | 评论(0) | 转发(0) |
0

上一篇:雅虎笔试题

下一篇:flash as3.0 进度条

给主人留下些什么吧!~~