让进程之间的通信更加灵活与高效，Linux的信号也可以传参数

realtang

代码如下，centOS 4.4编译运行通过

2. #include <unistd.h>
3. #include <signal.h>
4. #include <stdio.h>
5. #include <sys/types.h>
6. #include <sys/wait.h>
8. #define SIG_STOP_CHILD SIGRTMIN+1
10. int main()
11. {
12. pid_t pid;
13. sigset_t newmask;
14. int rcvd_sig;
15. siginfo_t info;
17.     if ((pid = fork()) == 0) {       /*Child*/
19.         sigemptyset(&newmask);
20.         sigaddset(&newmask, SIG_STOP_CHILD);
21.         sigprocmask(SIG_BLOCK, &newmask, NULL);
23.         while (1) {
24.             rcvd_sig = sigwaitinfo(&newmask, &info);
25.             if (rcvd_sig == -1) {
26.                perror("sigusr: sigwaitinfo");
27.                _exit(1);
28.             }
29.             else {
30.                  printf("Signal %d, value %d  received from parent\n",
31.                      rcvd_sig, info.si_value.sival_int);
32.                _exit(0);
33.             }
34.         }
35.     }
36.     else {                           /* Parent */
37.         sigval_t sval;
38.         sval.sival_int = 1;
39.         int stat;
40.         sleep(1);
41.         sigqueue(pid, SIG_STOP_CHILD, sval);
42.         pid = wait(&stat);
43.         printf("Child exit status = %d\n", WEXITSTATUS(stat));
44.         _exit(0);
45.     }
46. }

复制代码

realtang

因为只能传个int值给子进程，似乎还不够好，下面一个程序用共享内存的机制，实现传更多的数据给子进程。debian sid 编译运行通过。

2. #include <unistd.h>
3. #include <signal.h>
4. #include <stdio.h>
5. #include <sys/types.h>
6. #include <sys/wait.h>
7. #include <sys/ipc.h>
8. #include <sys/shm.h>
9. #include <stdlib.h>
10. #include <fcntl.h>
12. /* ERROR PRINT*/
13. #define STD_FUNC "Standard function "
15. #define SIG_STOP_CHILD SIGRTMIN+1
17. #define BUFSIZE 4096
19. int main()
20. {
21.         pid_t pid;
22.         sigset_t newmask;
23.         int rcvd_sig;
24.         siginfo_t info;
25.         char tmpnm[L_tmpnam] = "";
26.         if( NULL == tmpnam(tmpnm)) {
27.                 perror( STD_FUNC "tmpnamm failed:");
28.                 exit(-1);
29.         }
30.         int fd = open(tmpnm, O_CREAT | O_EXCL);
31.         if( -1 == fd) {
32.                 perror( STD_FUNC "open failed:");
33.                 exit(-1);
34.         }
35.         key_t shk = ftok(tmpnm, 'X');
36.         if( -1 == shk) {
37.                 perror( STD_FUNC "ftok failed:");
38.                 exit(-1);
39.         }
40.         int shm_id = shmget(shk, BUFSIZE+1, IPC_CREAT | IPC_EXCL);
41.         if ( -1 == shm_id) {
42.                 perror( STD_FUNC "shmget failed:");
43.                 exit( -1);
44.         }
46.        
47.     if ((pid = fork()) == 0) {       /*Child*/
49.         sigemptyset(&newmask);
50.         sigaddset(&newmask, SIG_STOP_CHILD);
51.         sigprocmask(SIG_BLOCK, &newmask, NULL);
53.         while (1) {
54.             rcvd_sig = sigwaitinfo(&newmask, &info);
55.             if (rcvd_sig == -1) {
56.                perror("sigusr: sigwaitinfo");
57.                _exit(1);
58.             }
59.             else {
60.                                 char * shm_buf = (char *)shmat(shm_id, NULL, 0);
61.                                 if( (char *)-1 == shm_buf) {
62.                                         perror( STD_FUNC"shmat failed:");
63.                                         exit(-1);
64.                                 }               
65.                                 printf("Signal %d, value %d  string "%s" received from parent\n",
66.                      rcvd_sig, info.si_value.sival_ptr, shm_buf);
67.                                 shmdt( shm_buf);
68.                _exit(0);
69.             }
70.         }
71.     }
72.     else {                           /* Parent */
73.         sigval_t sval;
74.         sval.sival_int = 1;
75.                 char * shm_buf = (char *)shmat(shm_id, NULL, 0);
76.                 if( (char *)-1 == shm_buf) {
77.                         perror( STD_FUNC "shmat failed:");
78.                         exit(-1);
79.                 }
80.                 sprintf( shm_buf, "%s", "Hello World!");
81.         int stat;
82.         sleep(1);
83.         sigqueue(pid, SIG_STOP_CHILD, sval);
84.         pid = wait(&stat);
85.         printf("Child exit status = %d\n", WEXITSTATUS(stat));
86.                 shmdt( shm_buf);
87.                 shmctl(shm_id, IPC_RMID, NULL);
88.                 close(fd);
89.         _exit(0);
90.     }
91. }

复制代码

DoDo

realtang 兄的文章篇篇都是精品, 偶像啊!

rickxbx

http://www.ibm.com/developerwork ... c/part2/index2.html

realtang

多谢rickxbx兄补充。