Chinaunix首页 | 论坛 | 博客
  • 博客访问: 3426369
  • 博文数量: 198
  • 博客积分: 0
  • 博客等级: 民兵
  • 技术积分: 7246
  • 用 户 组: 普通用户
  • 注册时间: 2013-01-23 18:56
个人简介

将晦涩难懂的技术讲的通俗易懂

文章分类

全部博文(198)

文章存档

2023年(9)

2022年(4)

2021年(12)

2020年(8)

2019年(18)

2018年(19)

2017年(9)

2016年(26)

2015年(18)

2014年(54)

2013年(20)

分类: LINUX

2013-09-22 19:37:23

问题模型:
初始:S1=1,S2=0;
父进程:P(S2)
            print
           V(S1)

子进程:P(S1)
            print
            V(S2)
在不同进程间使用线程上锁的要求:(1)互斥锁变量必须存放在由所有进程共享的内存区中
                                                (2)必须告知线程库函数这是在不同进程之间共享的互斥锁
第一个要求可以使用文件映射技术建立父子进程的共享存储区;第二个要求可以通过设置互斥锁的
PTHREAD_PROCESS_SHARED属性。

点击(此处)折叠或打开

  1. /*
  2. *线程同步对象:互斥量,读写锁,条件变量通常用于线程同步,但这些同步对象都有一个“进程共享属性”,
  3. *当对相应同步对象设置了这个属性,这些对象就能用于进程间的控制。
  4. */
  5. #include <stdio.h>
  6. #include <stdlib.h>
  7. #include <pthread.h>
  8. #include <fcntl.h>
  9. #include <sys/mman.h>

  10. static pthread_mutex_t *mptr1;//定义两个互斥锁指针分别指向S1,S2
  11. static pthread_mutex_t *mptr2;

  12. int
  13. main(int argc,char** argv)
  14. {
  15.   int i,fd;
  16.   pthread_mutexattr_t mattr1;//互斥锁属性
  17.   pthread_mutexattr_t mattr2;
  18.   if(argc<2)
  19.     return;
  20.   i=atoi(argv[1]);//交替输出的次数
  21.   fd=open("/dev/zero",O_RDWR,0);
  22.   mptr1=mmap(0,2*sizeof(pthread_mutex_t),PROT_READ|PROT_WRITE,MAP_SHARED,fd,0);//建立共享存储区,大小能容纳两个互斥锁,并是第一个互斥锁指针指向共享存储区开始的位置
  23.   close(fd);
  24.   mptr2=mptr1+sizeof(pthread_mutex_t);//第二个互斥锁的位置

  25.   pthread_mutexattr_init(&mattr1);//初始化互斥锁的属性
  26.   pthread_mutexattr_setpshared(&mattr1,PTHREAD_PROCESS_SHARED);//设置互斥锁属性为进程共享
  27.   pthread_mutex_init(mptr1,&mattr1); //将进程共享属性设置在相应互斥锁上

  28.   pthread_mutexattr_init(&mattr2);//同样设置第二个互斥锁的属性
  29.   pthread_mutexattr_setpshared(&mattr2,PTHREAD_PROCESS_SHARED);
  30.   pthread_mutex_init(mptr2,&mattr2);

  31.   pthread_mutex_lock(mptr2); //使S2=0,父进程阻塞,子进程先执行
  32.   if(fork()==0)
  33.   {
  34.    while(i>0)
  35.     {
  36.       pthread_mutex_lock(mptr1);//P(S1)

  37.       printf("child:%d\n",i);
  38.       i--;
  39.       
  40.       pthread_mutex_unlock(mptr2);//V(S2)
  41.     }
  42.    exit(0);
  43.   }
  44.   while(i>0)
  45.   {
  46.     pthread_mutex_lock(mptr2);//P(S2)

  47.     printf("parent:%d\n",i);
  48.     i--;

  49.     pthread_mutex_unlock(mptr1);//V(S1)
  50.   }
  51.   exit(0);
  52. }

运行结果:
阅读(5423) | 评论(0) | 转发(2) |
给主人留下些什么吧!~~