POSIX信号量
POSIX信号量信号量的概念
信号量可以用于多个不同进程间或者同一个进程中多个不同线程间进行同步的方案，Linux系统提供了POSIX信号量和IPC对象中的信号量集供用户使用。
POSIX信号量一般用于描述一种共享资源的状态，Linux系统把POSIX信号量分为两种：一种是POSIX匿名信号量，另一种则是POSIX具名信号量，两者区别如下所示：Linux系统中的信号量可以用于进程间通信，也可以用于同一个进程中多个线程的通信，而POSIX匿名信号量则是专门在进程中的多个线程间进行使用的一种信号量，也就是只存在于内存中。POSIX匿名信号量主要是在进程中的多条线程中使用，而POSIX具名信号量则主要是在多个进程中使用，并且可以存储在根文件系统的 /dev/shm 目录下，可以被系统中任意有权限的进程访问。
(1)匿名信号量
A. 初始化POSIX匿名信号量
Linux系统中提供了一个名称叫做sem_init()的函数接口，用户利用该接口可以对POSIX匿名信号量进行初始化。。
B. POSIX具名信号量进行P/V操作
对于信号量而言，都是对资源的一种数量的表示，所以进程或者线程在有限的资源进行访问时都需要进行申请和释放，所以Linux系统下提供了两个函数来实现POSIX具名信号量的P/V操作，分别是sem_wait()和sem_post()。
C.练习
练习：设计一个程序，要求在进程中存在两条线程，主线程获取键盘的字符串并输入到数组中，子线程等待主线程输入完成后，在把数组中的字符串输出到终端。要求使用POSIX信号量实现线程的同步。
#include <semaphore.h>
#include <stdio.h>
#include <pthread.h>
//全局变量
sem_t sem;
char buf={0};
//子线程
void * task(void *arg)
{
//设置分离属性
pthread_detach(pthread_self());
while(1)
{
//对匿名信号量进行P操作
sem_wait(&sem);//p操作
//打印数组中的字符
printf("I am pthread,buf=[%s]\n",buf);
bzero(buf,sizeof(buf));
//对匿名信号量进行P操作
sem_post(&sem);//V操作
}
}
int main()
{
//1.创建一个线程
pthread_t thread;
pthread_create(thread,NULL,task,NULL);
//2.初始化信号量
sem_init(&sem,0,1);
//3.键盘输入
while(1)
{
sem_wait(&sem);//p操作
scanf("请输入：%s\n",buf);
sem_post(&sem);//V操作
}
sem_close(&sem);
return 0;(2)有名信号量
POSIX匿名信号量主要是在进程中的多条线程中使用，而POSIX具名信号量则主要是在多个进程中使用，并且可以存储在根文件系统的 /dev/shm 目录下，可以被系统中任意有权限的进程访问。
A. 创建或者打开POSIX具名信号量
由于POSIX具名信号量有自己的文件名称，所以Linux系统提供了一个名称叫做sem_open()的函数接口，用户可以利用该接口创建或者打开POSIX具名信号量。
B. 对POSIX信号量进行P/V
对于信号量而言，都是对资源的一种数量的表示，所以进程或者线程在有限的资源进行访问时都需要进行申请和释放，所以Linux系统下提供了两个函数来实现POSIX匿名信号量的P/V操作，分别是sem_wait()和sem_post()。
注意：如果POSIX具名信号量使用完成后，应该及时关闭，Linux系统提供了名字叫做sem_close()的函数实现该操作。
另外，POSIX具名信号量创建完成后是存储在文件系统中的，所以并不会因为进程的结束而被删除，如果用户后期不打算继续使用POSIX具名信号量，linux系统提供了名称叫做sem_unlink()的函数接口实现删除POSIX具名信号量。
C.练习
练习：设计两个程序A和B，程序A和程序B需要创建一个共享内存，然后要求程序A把自己的PID写入到共享内存中，当程序A写入完成后，程序B从共享内存中读取程序A的PID并输出到终端，要求双方使用POSIX具名信号量实现同步。
进程A
#include <fcntl.h> /* For O_* constants */
#include <sys/stat.h> /* For mode constants */
#include <semaphore.h>
#include <sys/shm.h>
#include <stdio.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <stdlib.h>
#include <unistd.h>
int main()
{
//1.创建共享内存
int shm_id=shmget(ftok(".",3),4,IPC_CREAT|IPC_EXCL|664);
if (shm_id == -1)
{
if(errno == EEXIST)
{
//此时可以再次调用该函数打开共享内存
shm_id = shmget(ftok(".",50),4,0644);
}
else
{
fprintf(stderr, "shmget error,errno:%d,%s\n",errno,strerror(errno));
exit(1);
}
}
//2.把打开的共享内存段映射到自己的进程空间中
int * pshm = (int *)shmat(shm_id,NULL,0);
//3.打开一个POSIX有名信号量，如果不存在则创建
sem_t * psem = sem_open("named_sem", O_CREAT|O_EXCL,0644,0);
if(psem == SEM_FAILED)
{
if(errno == EEXIST)
{
//此时可以再次调用该函数打开共享内存
psem = sem_open("named_sem",0);
}
else
{
fprintf(stderr, "sem_open error,errno:%d,%s\n",errno,strerror(errno));
exit(2);
}
}
//4.进程A先对临界资源进行访问，然后对POSIX信号量进行V操作
*pshm = getpid();
sem_post(psem);
return 0;
}进程B
#include <fcntl.h> /* For O_* constants */
#include <sys/stat.h> /* For mode constants */
#include <semaphore.h>
#include <sys/shm.h>
#include <stdio.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <stdlib.h>
#include <unistd.h>
int main(int argc, char const *argv[])
{
//1.打开一个共享内存，如果不存在则创建
int shm_id = shmget(ftok(".",50),4,IPC_CREAT|IPC_EXCL|0644);
if (shm_id == -1)
{
if(errno == EEXIST)
{
//此时可以再次调用该函数打开共享内存
shm_id = shmget(ftok(".",50),4,0644);
}
else
{
fprintf(stderr, "shmget error,errno:%d,%s\n",errno,strerror(errno));
exit(1);
}
}
//2.把打开的共享内存段映射到自己的进程空间中
int * pshm = (int *)shmat(shm_id,NULL,0);
//3.打开一个POSIX有名信号量，如果不存在则创建
sem_t * psem = sem_open("named_sem", O_CREAT|O_EXCL,0644,0);
if(psem == SEM_FAILED)
{
if(errno == EEXIST)
{
//此时可以再次调用该函数打开共享内存
psem = sem_open("named_sem",0);
}
else
{
fprintf(stderr, "sem_open error,errno:%d,%s\n",errno,strerror(errno));
exit(2);
}
}
//4.死循环，防止进程终止
while(1)
{
//进程B必须等待进程A把PID写入到共享内存中之后才可以输出共享内存段中的数据
//进程B需要进行P操作
sem_wait(psem);
//访问临界资源
printf("shared memory data is [%d]\n",*pshm);
}
return 0;
}
来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！
页:
[1]