漯河网站建设漯河,快速排名工具免费查询,中国建设监督网站,塔城网站seo信号灯集 1、概念 信号灯(semaphore)#xff0c;也叫信号量。它是不同进程间或一个给定进程内部不同线程间同步的机制#xff1b;System V的信号灯是一个或者多个信号灯的一个集合。其中的每一个都是单独的计数信号灯。而Posix信号灯指的是单个计数信号灯。 通过信号灯集实现… 信号灯集 1、概念 信号灯(semaphore)也叫信号量。它是不同进程间或一个给定进程内部不同线程间同步的机制System V的信号灯是一个或者多个信号灯的一个集合。其中的每一个都是单独的计数信号灯。而Posix信号灯指的是单个计数信号灯。 通过信号灯集实现共享内存的同步操作。 步骤 在不同的进程间通过相同的key值打开相同的信号灯集 创建key值 ftok创建或打开信号灯集semget初始化信号灯 semctlPV操作 semop删除信号灯集 semctl 函数 1)semget 创建\打开信号灯 int semget(key_t key, int nsems, int semflg);
功能创建/打开信号灯
参数keyftok产生的key值nsems信号灯集中包含的信号灯数目semflg信号灯集的访问权限通常为IPC_CREAT |IPC_EXCL |0666
返回值成功信号灯集ID失败-12semctl 信号灯集合的控制初始化/删除 int semctl ( int semid, int semnum, int cmd…/*union semun arg*/);
功能信号灯集合的控制初始化/删除
参数semid信号灯集IDsemnum: 要操作的集合中的信号灯编号cmdGETVAL获取信号灯的值返回值是获得值SETVAL设置信号灯的值需要用到第四个参数共用体IPC_RMID从系统中删除信号灯集合
返回值成功 0失败 -1
用法初始化
union semun{int val;
}mysemun;
mysemun.val 10;
semctl(semid, 0, SETVAL, mysemun);
获取信号灯值函数semctl(semid, 0, GETVAL)的返回值
删除信号灯集semctl(semid, 0, IPC_RMID);3semop 对信号灯集合中的信号量进行PV操作 int semop ( int semid, struct sembuf *opsptr, size_t nops);
功能对信号灯集合中的信号量进行PV操作
参数semid信号灯集IDopsptr:操作方式nops: 要操作的信号灯的个数 1个
返回值成功 0失败-1
struct sembuf {short sem_num; // 要操作的信号灯的编号short sem_op; // 0 : 等待直到信号灯的值变成0// 1 : 释放资源V操作// -1 : 申请资源P操作 short sem_flg; // 0阻塞,IPC_NOWAIT, SEM_UNDO
};
用法
申请资源 P操作mysembuf.sem_num 0;mysembuf.sem_op -1;mysembuf.sem_flg 0;semop(semid, mysembuf, 1);
释放资源 V操作mysembuf.sem_num 0;mysembuf.sem_op 1;mysembuf.sem_flg 0;semop(semid, mysembuf, 1);#include stdio.h
#include sys/types.h
#include sys/ipc.h
#include sys/sem.h
#include errno.hunion semun {int val;
};int main(int argc, char const *argv[])
{//1.创建key值key_t key ftok(., x);if (key 0){perror(ftok err);return -1;}printf(key:%d\n, key);//2.创建或打开信号灯集int semid semget(key, 2, IPC_CREAT | IPC_EXCL | 0666); //创建if (semid 0) //创建失败{if (errno 17)semid semget(key, 2, 0666); //打开else{perror(semget err);return -1;}}else //创建成功--初始化{//初始化//创建初始化union semun sem;sem.val 0;semctl(semid, 0, SETVAL, sem); //0号灯初值0sem.val 10;semctl(semid, 1, SETVAL, sem); //1号灯初值10}printf(semid:%d\n, semid);printf(%d\n, semctl(semid, 0, GETVAL));printf(%d\n, semctl(semid, 1, GETVAL));//PV操作struct sembuf buf;// 操作0号灯buf.sem_num 0; //信号灯得编号buf.sem_op 1; //释放资源 : 1buf.sem_flg 0;//1:操作1个灯semop(semid, buf, 1);printf(%d\n, semctl(semid, 0, GETVAL));//操作1号灯buf.sem_num 1; //信号灯得编号buf.sem_op -1; //申请资源:-1buf.sem_flg 0; //当信号灯得资源为0时,申请不到资源,阻塞//IPC_NOWAIT:到0不阻塞//1:操作一个灯semop(semid, buf, 1);printf(%d\n, semctl(semid, 1, GETVAL));//删除信号灯集semctl(semid, 0, IPC_RMID);return 0;
} 命令查看灯集 ipcs -s:查看信号灯集 ipcrm -s semid删除信号灯集 练习 两个进程实现通信一个进程循环从终端输入另一个进程循环打印当输入quit时结束 共享内存信号灯集封装函数自主选择 #include stdio.h
#include sys/types.h
#include sys/ipc.h
#include sys/shm.h
#include sys/sem.h
#include errno.h
#include string.h
#include unistd.hunion semun {int val;
};int main(int argc, char const *argv[])
{//创建keykey_t key ftok(., a);if (key 0){perror(ftok err);return -1;}printf(key:%d\n, key);//创建或打开共享内存int shmid shmget(key, 256, IPC_CREAT | IPC_EXCL | 0666);if (shmid 0){if (errno 17)shmid shmget(key, 256, 0666);else{perror(shmget err);return -1;}}printf(shmid:%d\n, shmid);//映射char *p shmat(shmid, NULL, 0);if (p (char *)-1){perror(shmat err);return -1;}//创建或打开信号灯集int semid semget(key, 1, IPC_CREAT | IPC_EXCL | 0666);if (semid 0){if (errno 17)semid semget(key, 1, 0666);else{perror(semget err);return -1;}}else{//初始化union semun sem;sem.val 0;semctl(semid, 0, SETVAL, sem);}//写struct sembuf s;s.sem_num 0;s.sem_op 1;s.sem_flg 0;while (1){read(0, p, 256);semop(semid, s, 1);if (!strcmp(p, quit\n))break;}//取消映射shmdt(p);return 0;
} #include stdio.h
#include sys/types.h
#include sys/ipc.h
#include sys/shm.h
#include sys/sem.h
#include errno.h
#include string.h
#include unistd.hunion semun {int val;
};int main(int argc, char const *argv[])
{//创建keykey_t key ftok(., a);if (key 0){perror(ftok err);return -1;}printf(key:%d\n, key);//创建或打开共享内存int shmid shmget(key, 256, IPC_CREAT | IPC_EXCL | 0666);if (shmid 0){if (errno 17)shmid shmget(key, 256, 0666);else{perror(shmget err);return -1;}}printf(shmid:%d\n, shmid);//映射char *p shmat(shmid, NULL, 0);if (p (char *)-1){perror(shmat err);return -1;}//创建或打开信号灯集int semid semget(key, 1, IPC_CREAT | IPC_EXCL | 0666);if (semid 0){if (errno 17)semid semget(key, 1, 0666);else{perror(semget err);return -1;}}else{//初始化union semun sem;sem.val 0;semctl(semid, 0, SETVAL, sem);}//读struct sembuf s;s.sem_num 0;s.sem_op -1;s.sem_flg 0;while (1){semop(semid, s, 1);if (!strcmp(p, quit\n))break;write(1, p, 256);//清空memset(p, 0, 256);}//取消映射shmdt(p);//删除shmctl(shmid, IPC_RMID, NULL);semctl(semid, 0, IPC_RMID);return 0;
} 消息队列 1、特点 消息队列是IPC对象的一种 消息队列由消息队列ID来唯一标识 消息队列就是一个消息的列表。用户可以在消息队列中添加消息、读取消息等。 消息队列可以按照类型来发送(添加)/接收读取消息 2.步骤 在不同的进程中通过相同的key值拿到相同的消息队列 创建key值 ftok创建或打开消息队列 msgget添加消息按照类型将消息添加到已经打开的消息队列末尾 msgsnd读取消息按照类型把消息从消息队列中读走 msgrcv删除消息队列 msgctl 3.函数 1)msgget创建或打开一个消息队列 #include sys/types.h
#include sys/ipc.h
#include sys/msg.h
int msgget(key_t key, int flag);
功能创建或打开一个消息队列
参数 key值flag创建消息队列的权限IPC_CREAT|IPC_EXCL|0666
返回值成功msgid失败-1 2)msgsnd添加消息 #include sys/types.h
#include sys/ipc.h
#include sys/msg.h
int msgsnd(int msqid, const void *msgp, size_t size, int flag);
功能添加消息
参数msqid消息队列的IDmsgp指向消息的指针。常用消息结构msgbuf如下struct msgbuf{long mtype; //消息类型char mtext[N]} //消息正文size发送的消息正文的字节数flagIPC_NOWAIT消息没有发送完成函数也会立即返回 0直到发送完成函数才返回
返回值成功0失败-1
使用msgsnd(msgid, msg,sizeof(msg)-sizeof(long), 0)
注意消息结构除了第一个成员必须为long类型外其他成员可以根据应用的需求自行定义。 3)msgrcv读取消息 #include sys/types.h
#include sys/ipc.h
#include sys/msg.h
int msgrcv(int msgid, void* msgp, size_t size, long msgtype, int flag);
功能读取消息
参数msgid消息队列的IDmsgp存放读取消息的空间size接受的消息正文的字节数msgtype0接收消息队列中第一个消息。大于0接收消息队列中第一个类型为msgtyp的消息.小于0接收消息队列中类型值不小于msgtyp的绝对值且类型值又最小的消息。flag0若无消息函数会一直阻塞IPC_NOWAIT若没有消息进程会立即返回ENOMSG
返回值成功接收到的消息的长度失败-1 msgctl对消息队列的操作删除消息队列 #include sys/types.h
#include sys/ipc.h
#include sys/msg.h
int msgctl ( int msgqid, int cmd, struct msqid_ds *buf );
功能对消息队列的操作删除消息队列
参数msqid消息队列的队列IDcmdIPC_STAT读取消息队列的属性并将其保存在buf指向的缓冲区中。IPC_SET设置消息队列的属性。这个值取自buf参数。IPC_RMID从系统中删除消息队列。buf消息队列缓冲区
返回值成功0失败-1
用法msgctlmsgid, IPC_RMID, NULL#include stdio.h
#include sys/types.h
#include sys/ipc.h
#include sys/msg.h
#include errno.h
#include string.hstruct msgbuf
{long mtype;char name[32];int age;float score;
};int main(int argc, char const *argv[])
{//1、创建key值key_t key ftok(., a);if (key 0){perror(ftok err);return -1;}printf(key:%d\n, key);//2、创建或打开消息对列int msgid msgget(key, IPC_CREAT | IPC_EXCL | 0666);if (msgid 0){if (errno EEXIST)msgid msgget(key, 0666);else{perror(msgget err);return -1;}}printf(msgid:%d\n, msgid);//3、添加消息struct msgbuf msg;msg.mtype 1;strcpy(msg.name, daming);msg.age 18;msg.score 99.99;msgsnd(msgid, msg, sizeof(msg) - sizeof(long), 0); msg.mtype 3;strcpy(msg.name, lihua);msg.age 20;msg.score 69.5;msgsnd(msgid, msg, sizeof(msg) - sizeof(long), 0);//4、读取消息struct msgbuf msg_r;//0:可以匹配任意类型的消息,拿取得是消息对列得第一条消息msgrcv(msgid, msg_r, sizeof(msg_r) - sizeof(long),0, 0);printf(name:%s\n, msg_r.name);printf(age:%d\n, msg_r.age);printf(score:%.2f\n, msg_r.score);msgrcv(msgid, msg_r, sizeof(msg_r) - sizeof(long),3, 0);printf(name:%s\n, msg_r.name);printf(age:%d\n, msg_r.age);printf(score:%.2f\n, msg_r.score);//删除消息队列msgctl(msgid,IPC_RMID,NULL);return 0;
} 4.命令 ipcs -q 查看消息队列 ipcrm -q msgid 删除消息队列
