#include #include #include #include #include #include #includeusingnamespacestd;
// 进程退出函数void print_exit()
{
printf("the exit pid:[%d]
",getpid() );
}
int main()
{
string sMatch;
pid_t pid, child_pid;
vector<string> provList;
provList.push_back("taskFace");
provList.push_back("taskObj");
provList.push_back("taskAction");
provList.push_back("taskHat");
provList.push_back("taskOther");
cout << "Main process,id=" << getpid() << endl;
// 循环处理"100,200,300,400,500"for (vector<string>::iterator it = provList.begin(); it != provList.end(); ++it)
{
sMatch = *it;
atexit( print_exit );
pid = fork();
// (*hsq*)子进程退出循环,不再创建子进程,全部由主进程创建子进程,这里是关键所在if(pid == 0 || pid == -1)
{
break;
}
}
if(pid == -1)
{
cout<<"Fail to fork!"<exit(1);
}
elseif(pid == 0)
{
// 这里写子进程处理逻辑cout <<"This is children process,id=" << getpid() << ",start to process " << sMatch << endl;
sleep(10);
exit(0);
}
else
{
// 这里主进程处理逻辑cout << "This is main process,id=" << getpid() <<",end to process "<< sMatch << endl;
do
{
// WNOHANG 非阻塞 轮询 等待带子进程结束
child_pid = waitpid(pid, NULL, WNOHANG);
if(child_pid != pid)
{
printf("---- watpid error!
");
}
printf("I am main progress.The pid progress has not exited!
");
sleep(2);
}while(child_pid == 0);
exit(0);
}
return0;
}
执行结果
4.父进程子进程从哪里开始执行的问题
#include #include
main ()
{
pid_t pid;
printf("hello!
");
pid=fork();
if (pid < 0)
printf("error in fork!");
elseif (pid == 0)
printf("i am the child process, my process id is %d
",getpid());
elseprintf("i am the parent process, my process id is %d
",getpid());
printf("bye!
");
}
这里可以看出parent process执行了printf(“hello!
”); 而child process 没有执行printf(“hello!
”);
有一个让人很迷惑的例子:
#include #include
main ()
{
pid_t pid;
printf("fork!"); //printf("fork!
")
pid=fork();
if (pid < 0)
printf("error in fork!
");
elseif (pid == 0)
printf("i am the child process, my process id is %d
",getpid());
elseprintf("i am the parent process, my process id is %d
",getpid());
}
此时打印输出了两个fork!这不免让人以为是child process从#include处开始执行,所以也执行了printf(“fork!”); 语句。
其实不然,出现这种问题的原因在于:
这就跟Printf的缓冲机制有关了,printf某些内容时,操作系统仅仅是把该内容放到了stdout的缓冲队列里了,并没有实际的写到屏幕上 。但是,只要看到有
, 则会立即刷新stdout,因此就马上能够打印了.mian函数(parent process)运行了printf(“fork!”) 后, “fork!”仅仅被放到了缓冲里,再运行到fork时,缓冲里面的 AAAAAA 被子进程(child process)继承了,因此在子进程度stdout缓冲里面就也有了”fork!”。所以,你最终看到的会是 “fork!” 被printf了2次!!!! 而mian函数(parent process)运行 printf(“fork!
”)后,”fork!” 被立即打印到了屏幕上,之后fork到的子进程(child process)里的stdout缓冲里不会有”fork!”内容 因此你看到的结果会是”fork!” 被printf了1次!!!!
该函数用来创建和访问一个消息队列
int msgget(key_t, key, int msgflg);
与其他的IPC机制一样,程序必须提供一个键来命名某个特定的消息队列。msgflg是一个权限标志,表示消息队列的访问权限,它与文件的访问权限一样。msgflg可以与IPC_CREAT做或操作,表示当key所命名的消息队列不存在时创建一个消息队列,如果key所命名的消息队列存在时,IPC_CREAT标志会被忽略,而只返回一个标识符,它返回一个以key命名的消息队列的标识符(非零整数),失败时返回-1.
1.2msgsnd函数
该函数用来把消息添加到消息队列中。
int msgsend(int msgid, constvoid *msg_ptr, size_t msg_sz, int msgflg);
msgid是由msgget函数返回的消息队列标识符。
msg_ptr是一个指向准备发送消息的指针,但是消息的数据结构却有一定的要求,指针msg_ptr所指向的消息结构一定要是以一个长整型成员变量开始的结构体,接收函数将用这个成员来确定消息的类型。所以消息结构要定义成这样:
struct my_message
{
longint message_type;
/* The data you wish to transfer*/
};
msg_sz是msg_ptr指向的消息的长度,注意是消息的长度,而不是整个结构体的长度,也就是说msg_sz是不包括长整型消息类型成员变量的长度。
msgflg用于控制当前消息队列满或队列消息到达系统范围的限制时将要发生的事情。
如果调用成功,消息数据的一分副本将被放到消息队列中,并返回0,失败时返回-1.
1.3 msgrcv函数
该函数用来从一个消息队列获取消息,它的原型为
int msgrcv(int msgid, void *msg_ptr, size_t msg_st, long int msgtype, int msgflg);
msgid, msg_ptr, msg_st的作用也函数msgsnd函数的一样。
msgtype可以实现一种简单的接收优先级。如果msgtype为0,就获取队列中的第一个消息。如果它的值大于零,将获取具有相同消息类型的第一个信息。如果它小于零,就获取类型等于或小于msgtype的绝对值的第一个消息。
msgflg用于控制当队列中没有相应类型的消息可以接收时将发生的事情。
调用成功时,该函数返回放到接收缓存区中的字节数,消息被复制到由msg_ptr指向的用户分配的缓存区中,然后删除消息队列中的对应消息。失败时返回-1.