淘先锋技术网

首页 1 2 3 4 5 6 7

线程互斥量pthread_mutex_t 

struct mt {
   	int num;
  	pthread_mutex_t mutex_com_write;
   	pthread_mutexattr_t mutexattr_com_write;
};

为什么使用线程锁

在多线程应用程序中，当多个线程共享相同的内存时，如同时访问一个变量时，需要确保每个线程看到一致的数据视图，即保证所有线程对数据的修改是一致的。

如下两种情况不存在不一致的问题：
每个线程使用的变量都是其他线程不会读取和修改的
变量是只读的

当一个线程在修改变量的值时，其他线程在读取这个变量时可能会得到一个不一致的值。

1、进程间pthread_mutex

A依赖的头文件

#include<pthread.h>

B函数声明

int pthread_mutexattr_destroy(pthread_mutexattr_t *attr);

int pthread_mutexattr_setpshared(pthread_mutexattr_t *attr, int pshared);

int pthread_mutexattr_init(pthread_mutexattr_t *attr);

关于pshared可供选的参数：

线程锁：PTHREAD_PROCESS_PRIVATE

进程锁：PTHREAD_PROCESS_SHARED

默认情况下是线程锁

#include <stdio.h>

#include <pthread.h>

#include <unistd.h>

#include <sys/stat.h>

#include <sys/types.h>

#include <fcntl.h>

#include <sys/mman.h>

#include <string.h>

#include <sys/wait.h>

 

struct mt {

   int num;

   pthread_mutex_t mutex;

   pthread_mutexattr_t mutexattr;

};

 

int main(void) {

   int fd,i,err;

   struct mt *mm;

   pid_t pid;

 

   fd = open("mt_test",O_CREAT|O_RDWR,0777);

   /*不需要write,文件里初始值为0*/

   ftruncate(fd,sizeof(*mm));

   mm = mmap(NULL,sizeof(*mm),PROT_READ|PROT_WRITE,MAP_SHARED,fd,0);

   close(fd);

 

   memset(mm,0,sizeof(*mm));

 

   /*初始化互斥对象属性*/

   pthread_mutexattr_init(&mm->mutexattr);

 

   /*

    *设置互斥对象为PTHREAD_PROCESS_SHARED共享，即可以在多个进程的

    *线程访问，PTHREAD_PROCESS_PRIVATE为同一进程的线程共享

    */

   pthread_mutexattr_setpshared(&mm->mutexattr,PTHREAD_PROCESS_SHARED);

 

   pthread_mutex_init(&mm->mutex,&mm->mutexattr);

 

   pid = fork();

   if(pid == 0) {

       /*加10次。相当于加10*/

       for(i = 0;i < 10;i++) {

           //在子进程上对文件进行上锁

           pthread_mutex_lock(&mm->mutex);

           (mm->num)++;

           printf("num++:%d\n",mm->num);

           //解锁

           pthread_mutex_unlock(&mm->mutex);

           sleep(1);

       }

   } else if(pid > 0) {

       /*父进程完成x+2,加10次，相当于加20*/

       for (i = 0;i < 10;i++) {

           pthread_mutex_lock(&mm->mutex);

           mm->num += 2;

           printf("num+=2:%d\n",mm->num);

           pthread_mutex_unlock(&mm->mutex);

           sleep(1);

       }

       wait(NULL);

   }

 

   err = pthread_mutex_destroy(&mm->mutex);

   if(err != 0) {

       printf("%s\n",strerror(err));

   }

 

   /*父子均需要释放 */

   munmap(mm,sizeof(*mm));

   unlink("mt_test");

   return 0;

}