linux 命名信号量实现进程间的互斥与同步

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78

#include <stdio.h> #include <errno.h> #include <semaphore.h> #include <fcntl.h> /*    命名信号量不带内存共享,编译时要带库文件-lpthread或-lrt    int sem_wait(sem_t *sem); //P操作,若是信号量大于零则减一,否则阻塞在该函数位置等待.    int sem_post(sem_t *sem); //V操作,信号量加一    sem_t *sem_open(const char *name, int oflag);//打开信号量,flag参数与打开普通文件的标记一样    sem_t *sem_open(const char *name, int oflag,mode_t mode, unsigned int value); //创建并打开信号量,value参数指的是信号量的初始值 int sem_unlink(const char *name);//删除系统创建的信号量 int sem_close(sem_t *sem);//关闭彻底销毁信号量  */ /*进程排斥*/ #define SEM_NAME "mysem" #define OPEN_FLAG O_RDWR|O_CREAT #define OPEN_MODE 00777 #define INIT_V    0 static sem_t *sem = NULL; static void mysem(char *str) {     int i = 0;     while('\0' != str[i])     {         printf("%c\n", str[i++]);         sleep(1);     } } /*单次同步, 把信号量先初始化为0*/ int main(void) {     pid_t pid = -1;     int ret = -1;     int status = -1;     //创建一个命名信号量     sem = sem_open(SEM_NAME, OPEN_FLAG, OPEN_MODE, INIT_V);     //创建子进程     pid = fork();     if(-1 == (ret = pid))     {         perror("fork failed: ");         goto _OUT;     }     if(0 == pid)     {         mysem("abcd");         //V操作         sem_post(sem);     }     if(0 < pid)     {         //P操作         sem_wait(sem);         mysem("1234");         //等待子进程结束         wait(&status);         //删掉在系统创建的信号量         sem_unlink(SEM_NAME);         //彻底销毁打开的信号量         sem_close(sem);     } _OUT:     return ret; }

2. [文件] sem_diedai_syn.c ~ 2KB     下载(81)     跳至 [1] [2] [3] [全屏预览]

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100

#include <stdio.h> #include <errno.h> #include <semaphore.h> #include <fcntl.h> #include <signal.h> /*    命名信号量不带内存共享,编译时要带库文件-lpthread或-lrt    int sem_wait(sem_t *sem); //P操作,若是信号量大于零则减一,否则阻塞在该函数位置等待.    int sem_post(sem_t *sem); //V操作,信号量加一    sem_t *sem_open(const char *name, int oflag);//打开信号量,flag参数与打开普通文件的标记一样    sem_t *sem_open(const char *name, int oflag,mode_t mode, unsigned int value); //创建并打开信号量,value参数指的是信号量的初始值 int sem_unlink(const char *name);//删除系统创建的信号量 int sem_close(sem_t *sem);//关闭彻底销毁信号量  */ #define SEM_NAME1 "mysem1" #define SEM_NAME2 "mysem2" #define OPEN_FLAG O_RDWR|O_CREAT #define OPEN_MODE 00777 static sem_t *sem1 = NULL; static sem_t *sem2 = NULL; //临界区 static void mysem(char *str) {     int i = 0;     while('\0' != str[i])     {         printf("%c\n", str[i++]);         sleep(1);     } } //信号捕捉处理 static void myhandler(void) {         //删掉在系统创建的信号量         sem_unlink(SEM_NAME1);         sem_unlink(SEM_NAME2);         //彻底销毁打开的信号量         sem_close(sem1);            sem_close(sem2);    } /*迭代同步,两个信号量，开始时一个为1，一个为0， 一个进程执行完换另一个进程运行*/ int main(void) {     pid_t pid = -1;     int ret = -1;     int status = -1;     //安装捕捉信号     signal(SIGINT,(void *)myhandler );     //创建一个命名信号量     sem1 = sem_open(SEM_NAME1, OPEN_FLAG, OPEN_MODE, 1);        sem2 = sem_open(SEM_NAME2, OPEN_FLAG, OPEN_MODE, 0);        //创建子进程     pid = fork();     if(-1 == (ret = pid))     {         perror("fork failed: ");         goto _OUT;     }     if(0 == pid)     {         while(1)         {         //P操作         sem_wait(sem1);         mysem("abcd");         //V操作         sem_post(sem2);         }     }     if(0 < pid)     {         while(1)         {         //P操作         sem_wait(sem2);         mysem("1234");         //V操作         sem_post(sem1);         }         //等待子进程结束         wait(&status);     } _OUT:     return ret; }

3. [文件] sem_paichi.c ~ 2KB     下载(92)     跳至 [1] [2] [3] [全屏预览]

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77

#include <stdio.h> #include <errno.h> #include <semaphore.h> #include <fcntl.h> /*    命名信号量不带内存共享,编译时要带库文件-lpthread或-lrt    int sem_wait(sem_t *sem); //P操作,若是信号量大于零则减一,否则阻塞在该函数位置等待.    int sem_post(sem_t *sem); //V操作,信号量加一    sem_t *sem_open(const char *name, int oflag);//打开信号量,flag参数与打开普通文件的标记一样    sem_t *sem_open(const char *name, int oflag,mode_t mode, unsigned int value);     //创建并打开信号量,value参数指的是信号量的初始值 int sem_unlink(const char *name);//删除系统创建的信号量 int sem_close(sem_t *sem);//关闭彻底销毁信号量  */ #define SEM_NAME "mysem" #define OPEN_FLAG O_RDWR|O_CREAT #define OPEN_MODE 00777 #define INIT_V    1 static sem_t *sem = NULL; static void mysem(char *str) {     int i = 0;     //P操作     sem_wait(sem);     while('\0' != str[i])     {         printf("%c\n", str[i++]);         sleep(1);     }     //V操作     sem_post(sem); } /*进程排斥,在临界区设置PV操作*/ int main(void) {     pid_t pid = -1;     int ret = -1;     int status = -1;     //创建一个命名信号量     sem = sem_open(SEM_NAME, OPEN_FLAG, OPEN_MODE, INIT_V);     //创建子进程     pid = fork();     if(-1 == (ret = pid))     {         perror("fork failed: ");         goto _OUT;     }           if(0 == pid)     {         mysem("abcd");     }           if(0 < pid)     {         mysem("1234");         //等待子进程结束         wait(&status);         //删掉在系统创建的信号量         sem_unlink(SEM_NAME);         //彻底销毁打开的信号量         sem_close(sem);     } _OUT:     return ret; }