进程间同步-白红宇

进程间同步

阅读量：593 次

发布时间：2019-03-12

本文共 1477 字，大约阅读时间需要 4 分钟。


   
 
   
 
   
  进程间使用mutex实现数据同步：
  
   
  #include 
     
      #include 
      
       #include 
       
        #include 
        
         #include 
         
          #include 
          
           #include 
           
            #include 
            
             struct mt { int num; pthread_mutex_t mutex; pthread_mutexattr_t mutexattr;};int main(void){ int fd, i; struct mt *mm; pid_t pid; // 创建共享内存区域并初始化 // 以下代码用于创建并打开一个共享内存区段 // fd = open("mt_test", O_CREAT | O_RDWR, 0777); // ftruncate(fd, sizeof(*mm)); // mm = mmap(NULL, sizeof(*mm), PROT_READ|PROT_write, MAP_SHARED, fd, 0); // close(fd); // unlink("mt_test"); mm = mmap(NULL, sizeof(*mm), PROT_READ|PROT_WRITE, MAP_SHARED|MAP_ANON, -1, 0); memset(mm, 0, sizeof(*mm)); // 初始化mutex属性并设置为进程共享 pthread_mutexattr_init(&mm->mutexattr); pthread_mutexattr_setpshared(&mm->mutexattr, PTHREAD_PROCESS_SHARE); // 初始化互斥锁 pthread_mutex_init(&mm->mutex, &mm->mutexattr); // 创建子进程 pid = fork(); if (pid == 0){ // 子进程执行 for (i = 0; i < 10; i++){ pthread_mutex_lock(&mm->mutex); mm->num++; printf("-child----num++ %d\n", mm->num); pthread_mutex_unlock(&mm->mutex); sleep(rand()%2 + 1); } } else if (pid > 0){ // 父进程执行 for (i = 0; i < 10; i++){ sleep(rand()%2); pthread_mutex_lock(&mm->mutex); mm->num += 2; printf("-parent---num+=2 %d\n", mm->num); pthread_mutex_unlock(&mm->mutex); } wait(NULL); // 等待子进程完成 } // 销毁锁和属性 pthread_mutexattr_destroy(&mm->mutexattr); pthread_mutex_destroy(&mm->mutex); munmap(mm, sizeof(*mm));}
            
           
          
         
        
       
      
     
  
   
  运行结果展示过程中，父节点每次增加2，而子节点每次增加1，整个过程体现了进程间使用互斥锁实现的同步机制。这样可以确保在多进程环境下共享变量的访问是安全的。