Linux Day13 ---信号量

定义：int semop(int semid, struct sembuf *sops, unsigned nsops);

sem_id：是由semget返回的信号量标识符

sem_ops是指向一个结构数组的指针，一下是成员：

 struct sembuf

 {

 unsigned short sem_num; //指定信号量集中的信号量下标 ，一般取0

short sem_op; //其值为-1，代表 P 操作，其值为 1，代表 V 操作

 short sem_flg; //SEM_UNDO 

};

semop()成功返回 0，失败返回-1

1.2.3 semctl函数

1.2.3 实现上述函数

头文件 sem.h

#include
#include
#include
#include
#include
#include
union semun{
    int val;
};
void sem_init();
void sem_p();
void sem_v();
void sem_destroy();

#include"sem.h"
int main()
{
    sem_init();//
    for(int i = 0; i < 5; i++)
    {
        //p
        sem_p();
        printf("a");
        fflush(stdout);
        int n = rand() % 3;
        sleep(n);
        printf("a");
        fflush(stdout);
        sem_v();
 
        n = rand() % 3;
        sleep(n);
    }
 
    sem_destroy();
    return 0;
}

#include"sem.h"
int main()
{
    sem_init();//
    for(int i = 0; i < 5; i++)
    {
        //p
        sem_p();
        printf("b");
        fflush(stdout);
        int n = rand() % 3;
        sleep(n);
        printf("b");
        fflush(stdout);
        sem_v();
 
        n = rand() % 3;
        sleep(n);
    }
    return 0;
}

共享内存为多个进程之间共享和传递数据提供了一种有效的方式。共享内存是先在物理

内存上申请一块空间，多个进程可以将其映射到自己的虚拟地址空间中。所有进程都可以访

问共享内存中的地址，就好像它们是由 malloc 分配的一样。如果某个进程向共享内存写入了

数据，所做的改动将立刻被可以访问同一段共享内存的任何其他进程看到。由于它并未提供

同步机制，所以我们通常需要用其他的机制来同步对共享内存的访问。

两个进程在进行通信，共用同一个物理内存，逻辑上不同，物理上共存。

2.2.1 shmget()

 shmget()成功返回共享内存的 ID， 失败返回-1

2.2.2 shmat()

 

2.2.3 shmdt()

 shmdt()断开当前进程的 shmaddr 指向的共享内存映射

2.2.4 shmctl()

2.3 举个栗子

step 1:不加信号量

step 2:使用信号量

step 3:代码实现

main.c

#include 
#include 
#include 
#include 
#include 
#include "sem.h"
 
int main()
{
    int shmid = shmget((key_t)1234,128,IPC_CREAT|0600);
    if ( shmid == -1 )
    {
        printf("shmget err\n");
        exit(1);
    }
 
    char* s = (char*)shmat(shmid,NULL,0);
    if ( s == (char*)-1) 
    {
        printf("shmat err\n");
        exit(1);
    }   
 
    sem_init();
    while( 1 )
    {
        printf("input\n");
        char buff[128] = {0};
        fgets(buff,128,stdin);
 
        sem_p(SEM1);
        strcpy(s,buff);
        sem_v(SEM2);
 
        if ( strncmp(buff,"end",3) == 0)
        {
            break;
        }
    }
 
    shmdt(s);
}

test.c

#include 
#include 
#include 
#include 
#include 
#include "sem.h"
 
int main()
{
    int shmid = shmget((key_t)1234,128,IPC_CREAT|0600);
    if ( shmid == -1 )
    {
        printf("shmget err\n");
        exit(1);
    }
 
    char * s = (char*)shmat(shmid,NULL,0);
    if ( s == (char*)-1)
    {
        printf("shmat err\n");
        exit(1);
    }
 
    sem_init();
    while( 1 )
    {
        sem_p(SEM2);
        if ( strncmp(s,"end",3) == 0 )
        {
            break;
        }
 
        printf("read:%s\n",s);
        sem_v(SEM1);
    }
 
    shmdt(s);
    shmctl(shmid,IPC_RMID,NULL);
    sem_destroy();
}