進程間同步可以使用互斥量mutex(互斥鎖)、信號量和文件鎖。
進程間同步使用信號量:
int sem_init(sem_t *sem, int pshared, unsigned int value);
用于進程間同步此時第二個參數不能取0了,取非0值用于進程間同步,一般取1,也可按照下述方法取值,即:PTHREAD_PROCESS_SHARED。
(1)進程間使用互斥量進行同步
在pthread_mutex_init初始化之前,修改其屬性為進程間共享。mutex的屬性修改函數主要有以下幾個:
pthread_mutexattr_t mattr 類型:用于定義mutex鎖的屬性;
int pthread_mutexattr_init(pthread_mutexattr_t *attr);? 初始化一個mutex屬性對象;
int pthread_mutexattr_setpshared(pthread_mutexattr_t *attr, int pshared);? 修改mutex屬性;參2:pshared取值:進程鎖:PTHREAD_PROCESS_SHARED;? 線程鎖:PTHREAD_PROCESS_PRIVATE (mutex的默認屬性即為線程鎖,進程間私有)
int pthread_mutexattr_destroy(pthread_mutexattr_t *attr); 銷毀mutex屬性對象 (而非銷毀鎖)
int pthread_mutex_init(pthread_mutex_t *restrict mutex, const pthread_mutexattr_t *restrict attr);? 即將修改后的屬性傳入該函數,即可產生一個進程鎖。
//進程間使用互斥量來實現同步
#include <fcntl.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include <sys/mman.h>
#include <sys/wait.h>struct mt {int num;pthread_mutex_t mutex;pthread_mutexattr_t mutexattr;
};int main(void)
{int i;struct mt *mm;pid_t pid;
/* 文件映射方式創建映射區int 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)); //初始化內存pthread_mutexattr_init(&mm->mutexattr); //初始化mutex屬性對象pthread_mutexattr_setpshared(&mm->mutexattr, PTHREAD_PROCESS_SHARED); //修改屬性為進程間共享pthread_mutex_init(&mm->mutex, &mm->mutexattr); //初始化一把mutex瑣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(1);}} else if (pid > 0) {for ( i = 0; i < 10; i++) {sleep(1);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); //銷毀mutex屬性對象pthread_mutex_destroy(&mm->mutex); //銷毀mutexmunmap(mm,sizeof(*mm)); //釋放映射區return 0;
}
[root@localhost 02_pthread_sync_test]# ./process_mutex
-child----------num++?? 1
-------parent---num+=2? 3
-child----------num++?? 4
-------parent---num+=2? 6
-child----------num++?? 7
-child----------num++?? 8
-------parent---num+=2? 10
-------parent---num+=2? 12
-child----------num++?? 13
-------parent---num+=2? 15
-child----------num++?? 16
-child----------num++?? 17
-------parent---num+=2? 19
-child----------num++?? 20
-------parent---num+=2? 22
-child----------num++?? 23
-------parent---num+=2? 25
-child----------num++?? 26
-------parent---num+=2? 28
-------parent---num+=2? 30