Linux操作系统分析(10) - 进程通信之管道与信号量
提要 Linux中进程间的通信机制主要有:管道和FIFO,信号量,消息,共享内存曲,套接字。程序员在使用中可以根据不同的需求进行选择。管道 管道(pipe)是所有Unix都愿意提供的一种进程间通信,最适合在进程之间实现生产者/消费者的交互。管道是进程之间的一个单向数据流,一个进程写入管道的所有数据都由内核定向到另一个进程,另一个进程由次就可以从管道中读取数据。
提要
Linux中进程间的通信机制主要有:管道FIFO,信号量,消息,共享内存区,套接字。程序员在使用中可以根据不同的需求进行选择。
管道
管道是由内核管理的一个缓冲区,相当于我们放入内存中的一个纸条。管道的一端连接一个进程的输出。这个进程会向管道中放入信息。管道的另一端连接一个进程的输入,这个进程取出被放入管道的信息。一个缓冲区不需要很大,它被设计成为环形的数据结构,以便管道可以被循环利用。当管道中没有信息的话,从管道中读取的进程会等待,直到另一端的进程放入信息。当管道被放满信息的时候,尝试放入信息的进程会等待,直到另一端的进程取出信息。当两个进程都终结的时候,管道也自动消失。
下面是一个简单的例子.先看两个linux中常用的命令
grep
功能说明:查找文件里符合条件的字符串。
语 法:grep [-abcEFGhHilLnqrsvVwxy][-A<显示列数>][-B<显示列数>][-C<显示列数>][-d<进行动作>][-e<范本样式>][-f<范本文件>][--help][范本样式][文件或目录...]
补充说明:grep 指令用于查找内容包含指定的范本样式的文件,如果发现某文件的内容符合所指定的范本样式,预设grep指令会把含有范本样式的那一列显示出来。若不指定任何文件名称,或是所给予的文件名为“-”,则grep指令会从标准输入设备读取数据。
ls
功能说明:列出目标目录中所有的子目录和文件。
语 法:ls [选项] [目录名]
通过 " | " 可以创建一个管道,把这两个进程链接在一起。
终端运行
ls | grep in
目录下文件名中带in的文件或文件夹会显示出来:
在linux的内核中实际上执行的操作如下:
1.调用pipe() 系统调用,假设pipe()返回文件描述符3(管道的读通道)和4(管道的写通道)。
2.两次调用fork() 系统调用。
3.两次调用close() 系统调用来释放文件描述符3和4.
使用管道
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
int pipe_default[2];
int main()
{
pid_t pid;
char buffer[32];
memset(buffer, 0, 32);
if(pipe(pipe_default) < 0)
{
printf("Faild to create pipe.\n");
return 0;
}
//Child process
if(0 == (pid =fork()))
{
close(pipe_default[1]);
if(read(pipe_default[0], buffer, 32) > 0)
{
printf("Receive data from server, %s!\n", buffer);
}
close(pipe_default[0]);
}else //Parent process
{
close(pipe_default[0]);
if(-1 != write(pipe_default[1], "Fuck", strlen("Fuck")))
{
printf("Send data to client,Fuck!\n");
}
close(pipe_default[1]);
waitpid(pid,NULL,0);
}
return 1;
}
主要解释一下几个相关的函数。
int pipe(int filedes[2]);
filedes[0]用于读出数据,读取时必须关闭写入端,即close(filedes[1]);
filedes[1]用于写入数据,写入时必须关闭读取端,即close(filedes[0])
void *memset(void *s, char ch, size_t n);
将s中前n个字节 (typedef unsigned int size_t)用 ch 替换并返回 s 。
pid_t waitpid(pid_t pid,int * status,int options);
暂时停止目前进程的执行,直到有信号来到或子进程结束。
read和write分别向管道中传送数据。
信号量
信号量在创建时需要设置一个初始值,表示同时可以有几个任务可以访问该信号量保护的共享资源,初始值为1就变成互斥锁(Mutex),即同时只能有一个任务可以访问信号量保护的共享资源。
一个任务要想访问共享资源,首先必须得到信号量,获取信号量的操作将把信号量的值减1,若当前信号量的值为负数,表明无法获得信号量,该任务必须挂起在该信号量的等待队列等待该信号量可用;若当前信号量的值为非负数,表示可以获得信号量,因而可以立刻访问被该信号量保护的共享资源。
当任务访问完被信号量保护的共享资源后,必须释放信号量,释放信号量通过把信号量的值加1实现,如果信号量的值为非正数,表明有任务等待当前信号量,因此它也唤醒所有等待该信号量的任务。
PV原子操作的具体定义如下:(好好理解,很重要的啊)
● P操作:如果有可用的资源(信号量值>0),则此操作所在的进程占用一个资源(此时信号量值减1,进入临界区代码);如果没有可用的资源(信号量值=0),则此操作所在的进程被阻塞直到系统将资源分配给该进程(进入等待队列,一直等到资源轮到该进程)。
● V操作:如果在该信号量的等待队列中有进程在等待资源,则唤醒一个阻塞进程;如果没有进程等待它,则释放一个资源(即信号量值加1)。
一个实现PV操作的例子。
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
#define DELAY_TIME 5
union semun
{
int val;
struct semid_ds *buf;
unsigned short *array;
};
int initsem(int sem_id, int init_value);
int del_sem(int sem_id);
int sem_p(int sem_id);
int sem_v(int sem_id);
int main(void)
{
pid_t result;
int sem_id;
sem_id = semget(ftok(".",'a'),1,0666|IPC_CREAT);
init_sem(sem_id, 0);
result = fork();
if(result == -1)
{
perror("fork error!\n");
}
else if(result == 0)
{
printf("Child process at id:%d, I run first.\n",getpid());
sleep(DELAY_TIME);
sem_v(sem_id);
}
else
{
sem_p(sem_id);
printf("Parent process at id:%d\n",getpid());
sem_v(sem_id);
del_sem(sem_id);
}
return 0;
}
int init_sem(int sem_id, int init_value)
{
union semun sem_union;
sem_union.val = init_value;
if(semctl(sem_id, 0, SETVAL, sem_union) == 1)
{
perror("Init semaphore!");
return -1;
}
return 0;
}
int del_sem(int sem_id)
{
union semun sem_union;
if(semctl(sem_id, 0, IPC_RMID, sem_union) == 1)
{
perror("Delete semaphore!");
return -1;
}
}
int sem_p(int sem_id)
{
struct sembuf sem_b;
sem_b.sem_num = 0;
sem_b.sem_op = -1;
sem_b.sem_flg = SEM_UNDO;
if(semop(sem_id, &sem_b, 1) == -1)
{
perror("P operation.");
return -1;
}
return 0;
}
int sem_v(int sem_id)
{
struct sembuf sem_b;
sem_b.sem_num = 0;
sem_b.sem_op = 1;
sem_b.sem_flg = SEM_UNDO;
if(semop(sem_id, &sem_b, 1) == -1)
{
perror("P operation.");
return -1;
}
return 0;
}
在程序中,由于使用了信号量,确保了每次执行子进程运行在父进程之前。
参考
Linux进程间通信(六)---信号量通信之semget()、semctl()、semop()及其基础实验 - http://blog.csdn.net/mybelief321/article/details/9086151
Linux环境进程间通信(一) - http://www.ibm.com/developerworks/cn/linux/l-ipc/part1/
更多推荐
所有评论(0)