提要

       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/

Logo

更多推荐