服务器

    详解Linux操作系统中多线程的同步

         [ 中国IT实验室 转载 ] 暂无评论

      1 互斥锁

      互斥锁用来保证一段时间内只有一个线程在执行一段代码。必要性显而易见:假设各个线程向同一个文件顺序写入数据,最后得到的结果一定是灾难性的。

      先看下面一段代码。这是一个读/写程序,它们公用一个缓冲区,并且假定一个缓冲区只能保存一条信息。即缓冲区只有两个状态:有信息或没有信息。

      void reader_function ( void );

      void writer_function ( void );

      char buffer;

      int buffer_has_item=0;

      pthread_mutex_t mutex;

      struct timespec delay;

      void main ( void ){

      pthread_t reader;

      /* 定义延迟时间*/

      delay.tv_sec = 2;

      delay.tv_nec = 0;

      /* 用默认属性初始化一个互斥锁对象*/

      pthread_mutex_init (&mutex,NULL);

      pthread_create(&reader, pthread_attr_default, (void *)&reader_function), NULL);

      writer_function( );

      }

      void writer_function (void){

      while(1){

      /* 锁定互斥锁*/

      pthread_mutex_lock (&mutex);

      if (buffer_has_item==0){

      buffer=make_new_item( );

      buffer_has_item=1;

      }

      /* 打开互斥锁*/

      pthread_mutex_unlock(&mutex);

      pthread_delay_np(&delay);

      }

      }

      void reader_function(void){

      while(1){

      pthread_mutex_lock(&mutex);

      if(buffer_has_item==1){

      consume_item(buffer);

      buffer_has_item=0;

      }

      pthread_mutex_unlock(&mutex);

      pthread_delay_np(&delay);

      }

      }

      这里声明了互斥锁变量mutex,结构pthread_mutex_t为不公开的数据类型,其中包含一个系统分配的属性对象。函数pthread_mutex_init用来生成一个互斥锁。NULL参数表明使用默认属性。如果需要声明特定属性的互斥锁,须调用函数pthread_mutexattr_init。函数pthread_mutexattr_setpshared和函数pthread_mutexattr_settype用来设置互斥锁属性。前一个函数设置属性pshared,它有两个取值,PTHREAD_PROCESS_PRIVATE和PTHREAD_PROCESS_SHARED。前者用来不同进程中的线程同步,后者用于同步本进程的不同线程。在上面的例子中,使用的是默认属性PTHREAD_PROCESS_ PRIVATE。后者用来设置互斥锁类型,可选的类型有PTHREAD_MUTEX_NORMAL、PTHREAD_MUTEX_ERRORCHECK、PTHREAD_MUTEX_RECURSIVE和PTHREAD _MUTEX_DEFAULT。它们分别定义了不同的上锁、解锁机制,一般情况下,选用最后一个默认属性。

      pthread_mutex_lock声明开始用互斥锁上锁,此后的代码直至调用pthread_mutex_unlock为止,均被上锁,即同一时间只能被一个线程调用执行。当一个线程执行到pthread_mutex_lock处时,如果该锁此时被另一个线程使用,那此线程被阻塞,即程序将等待到另一个线程释放此互斥锁。在上面的例子中,使用了pthread_delay_np函数,让线程睡眠一段时间,就是为了防止一个线程始终占据此函数。

      在使用互斥锁的过程中很有可能会出现死锁:两个线程试图同时占用两个资源,并按不同的次序锁定相应的互斥锁,例如两个线程都需要锁定互斥锁1和互斥锁2,a线程先锁定互斥锁1,b线程先锁定互斥锁2,这时就出现了死锁。此时可以使用函数pthread_mutex_trylock,它是函数pthread_mutex_lock的非阻塞版本,当它发现死锁不可避免时,它会返回相应的信息,程序员可以针对死锁做出相应的处理。另外不同的互斥锁类型对死锁的处理不一样,但最主要的还是要程序员自己在程序设计注意这一点。

    提示:支持键盘“← →”键翻页
    本文导航

    关注排行榜

    产品品牌

    文章推荐

    互动沙龙

    相关内容 网友评论 返回首页
    专家咨询