zoukankan      html  css  js  c++  java
  • POSIX 互斥锁: pthread_mutex_t

    #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 * add_1( void * cnt ) {    

      pthread_mutex_lock(&( ( (ct_sum*)cnt)->lock));    

      for( int i = 0 ; i <50 ; i++ )

        (*(ct_sum*)cnt).sum+=i;    

      pthread_mutex_unlock(&(((ct_sum*)cnt)->lock));    

      pthread_exit(NULL);    

      return 0;

    void * add_2 ( void * cnt ) {

      cnt = (ct_sum*)cnt;     

      pthread_mutex_lock(&(((ct_sum*)cnt)->lock));    

      for(int 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 ) {

      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,add_1,&cnt);    

      pthread_create(&ptid_2,NULL,add_2,&cnt);         

      pthread_mutext_lock(&(cnt.lock));    

      printf("sum : %d ",cnt.sum);    

      pthread_mutex_unlock(&(cnt.lock));

      pthread_join(ptid_1,NULL);    

      pthread_join(ptid_2,NULL);    

      pthread_mutex_destroy(&(cnt.lock));    

      return 0;

      //上面的例子未创建两个线程对sum从1加到100. 前面第一个线程从1-49,后面从50-100.主线程读取最后的加值.为了防止资源竞争,用了pthread_mutex_t锁操作.   

    简单的用法:

    pthread_mutex_t lock;

    pthread_mutex_int(&lock, NULL);

    ...

    pthread_mutex_lock(&lock);

    ...

    pthread_mutex_unlock(&lock);

    ...

    pthread_mutex_destroy(&lock);

    一直这么用, 也没有深究, 几天需要在不熟悉的代码中增加一段代码, 需要用到pthread_mutex_t, 但有不想在别的地方初始化, 查了一下, 发现这个POSIX的mutex还有点意思, 摘录如下:

    ///////////////////////////////////////////////////////////////////////////////

    其实也没得啥子特别的, 主要是mutex的几个属性以前确实不了解, 这下记住了.

    ///////////////////////////////////////////////////////////////////////////////

    该函数用于C函数的多线程编程中,互斥锁的初始化。 

    pthread_mutex_init() 函数是以动态方式创建互斥锁的,参数attr指定了新建互斥锁的属性。如果参数attr为空,则使用默认的互斥锁属性,默认属性为快速互斥锁 。互斥锁的属性在创建锁的时候指定,在LinuxThreads实现中仅有一个锁类型属性,不同的锁类型在试图对一个已经被锁定的互斥锁加锁时表现不同。 

    pthread_mutexattr_init() 函数成功完成之后会返回零,其他任何返回值都表示出现了错误。 

    函数成功执行后,互斥锁被初始化为未锁住态。 

    l 互斥锁pthread_mutex_t的使用: 

    1. 互斥锁创建 

    有两种方法创建互斥锁,静态方式和动态方式。POSIX定义了一个宏PTHREAD_MUTEX_INITIALIZER来静态初始化互斥锁,方法如下: 

    pthread_mutex_t mutex=PTHREAD_MUTEX_INITIALIZER; 

    在LinuxThreads实现中,pthread_mutex_t是一个结构,而PTHREAD_MUTEX_INITIALIZER则是一个结构常量。 

    动态方式是采用pthread_mutex_init()函数来初始化互斥锁,API定义如下: 

    int pthread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t *mutexattr) 

    其中mutexattr用于指定互斥锁属性(见下),如果为NULL则使用缺省属性。 

    pthread_mutex_destroy ()用于注销一个互斥锁,API定义如下: 

    int pthread_mutex_destroy(pthread_mutex_t *mutex) 

    销毁一个互斥锁即意味着释放它所占用的资源,且要求锁当前处于开放状态。由于在Linux中,互斥锁并不占用任何资源,因此LinuxThreads中的 pthread_mutex_destroy()除了检查锁状态以外(锁定状态则返回EBUSY)没有其他动作。 

    2. 互斥锁属性 

    互斥锁的属性在创建锁的时候指定,在LinuxThreads实现中仅有一个锁类型属性,不同的锁类型在试图对一个已经被锁定的互斥锁加锁时表现不同。当前(glibc2.2.3,linuxthreads0.9)有四个值可供选择: 

    * PTHREAD_MUTEX_TIMED_NP,这是缺省值,也就是普通锁。当一个线程加锁以后,其余请求锁的线程将形成一个等待队列,并在解锁后按优先级获得锁。这种锁策略保证了资源分配的公平性。

    * PTHREAD_MUTEX_RECURSIVE_NP,嵌套锁,允许同一个线程对同一个锁成功获得多次,并通过多次unlock解锁。如果是不同线程请求,则在加锁线程解锁时重新竞争。

    * PTHREAD_MUTEX_ERRORCHECK_NP,检错锁,如果同一个线程请求同一个锁,则返回EDEADLK,否则与PTHREAD_MUTEX_TIMED_NP类型动作相同。这样就保证当不允许多次加锁时不会出现最简单情况下的死锁。

    * PTHREAD_MUTEX_ADAPTIVE_NP,适应锁,动作最简单的锁类型,仅等待解锁后重新竞争。

    3. 锁操作 

    锁操作主要包括加锁 pthread_mutex_lock()、解锁pthread_mutex_unlock()和测试加锁pthread_mutex_trylock()三个,不论哪种类型的锁,都不可能被两个不同的线程同时得到,而必须等待解锁。对于普通锁和适应锁类型,解锁者可以是同进程内任何线程;而检错锁则必须由加锁者解锁才有效,否则返回EPERM;对于嵌套锁,文档和实现要求必须由加锁者解锁,但实验结果表明并没有这种限制,这个不同目前还没有得到解释。在同一进程中的线程,如果加锁后没有解锁,则任何其他线程都无法再获得锁。 

    int pthread_mutex_lock(pthread_mutex_t *mutex) 

    int pthread_mutex_unlock(pthread_mutex_t *mutex) 

    int pthread_mutex_trylock(pthread_mutex_t *mutex) 

    pthread_mutex_trylock()语义与pthread_mutex_lock()类似,不同的是在锁已经被占据时返回EBUSY而不是挂起等待。

  • 相关阅读:
    天梯赛5-12 愿天下有情人都是失散多年的兄妹 【dfs】
    poj2718 Smallest Difference【贪心】
    HDU problem 5635 LCP Array【思维】
    codeforces 782C Andryusha and Colored Balloons【构造】
    HDU 4278 Faulty Odometer【进制转换】
    codeforces B. The Meeting Place Cannot Be Changed【二分】
    POJ 3264 Balanced Lineup 【线段树】
    HDU 1850
    CodeForces-714C
    HDU Problem 1247 Hat's Words 【字典树】
  • 原文地址:https://www.cnblogs.com/liugangBlog/p/6285754.html
Copyright © 2011-2022 走看看