Linux非阻塞等待示例

简介: Linux非阻塞等待示例

非阻塞等待的意义:

非阻塞等待在多进程编程中的意义主要体现在提高系统的响应性、实现异步任务执行、动态任务管理和多任务协同工作等方面。它允许父进程在等待子进程退出的同时,继续执行其他任务,从而提高系统的并发性和效率,增加系统的灵活性和可扩展性。

简单的多进程编程示例

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>
#define TASK_NUM 5
typedef void (*task_t)();
void download()
{
    printf("this is a download task is rnning!(正在执行下载任务)\n");
}
void printLog()
{
    printf("this is a write log task is rnning!(正在执行日志任务)\n");
}
void show()
{
    printf("this is a show info task is rnning!(正在执行显示信息任务)\n");
}
void initTasks(task_t tasks[], int num)
{
    for(int i = 0; i < num; i++) tasks[i] = NULL;
}
int addTask(task_t tasks[], task_t t)
{
    int i = 0;
    for(; i < TASK_NUM; i++)
    {
        if(tasks[i] == NULL)
        {
            tasks[i] = t;
            return 1;
        }
    }
    return 0;
}
void executeTask(task_t tasks[], int num)
{
    for(int i = 0; i < num; i++)
    {
        if(tasks[i]) tasks[i]();
    }
}
void worker(int cnt)
{
    printf("I am child, pid: %d, cnt: %d\n", getpid(), cnt);
}
int main()
{
    task_t tasks[TASK_NUM];
    initTasks(tasks, TASK_NUM);
    addTask(tasks, download);
    addTask(tasks, printLog);
    addTask(tasks, show);
    pid_t id = fork();
    if(id == 0){
        // child
        int cnt = 10;
        while(cnt)
        {
            worker(cnt);
            sleep(2);
            cnt--;
        }
        exit(0);
    }
    while(1)
    {
        //father
        int status = 0;
        // 非阻塞等待,可以让等待方在返回的时候,顺便做做自己的事情
        pid_t rid = waitpid(id, &status, WNOHANG);
        if(rid > 0)
        {
            // wait success, child quit now;
            printf("child quit success(孩子退出成功), exit code: %d, exit signal: %d\n", (status>>8)&0xFF, status&0x7F);
            break;
        }
        else if(rid == 0)
        {
            printf("##################################################\n");
            // wait success, but child not quit
            printf("child is alive, wait again, father do other thing(孩子还活着,再次等待,父亲做其他事情)....\n");
            // 该函数内部,其实是回调式执行任务
            executeTask(tasks, TASK_NUM); // 也可以在内部进行自己移除&&新增对应的任务
            printf("##################################################\n");
        }
        else{
            // wait failed, child unknow
            printf("wait failed!\n");
            break;
        }
        sleep(1);
    }
    return 0;
}

运行结果:

代码解释

这段代码主要使用了 fork() 和 waitpid() 系统调用来创建和管理子进程。下面是代码的详细解释:

包含了必要的头文件:

<stdio.h>:标准输入输出库,用于输入输出操作。

<stdlib.h>:标准库,提供了一些通用工具函数,如内存分配和进程控制。

<unistd.h>:Unix 标准库,提供了对 POSIX 操作系统 API 的访问。

<sys/types.h>:包含了进程标识符 pid_t 的定义。

<sys/wait.h>:包含了等待进程结束的函数 waitpid() 的定义。

定义了一个常量 TASK_NUM,表示任务的数量。

typedef了一个函数指针类型 task_t,用于表示任务函数的类型。

定义了三个具体的任务函数 download()、printLog() 和 show(),用于演示任务的执行过程。这些函数只是简单地打印一些信息。

  • 定义了一个辅助函数 initTasks(),用于初始化任务数组。该函数会将任务数组中的所有元素设置为 NULL。
  • 定义了一个辅助函数 addTask(),用于将任务添加到任务数组中。该函数会遍历任务数组,找到第一个为 NULL 的位置,并将任务函数指针存储在该位置。如果找不到空闲位置,则返回 0;否则返回 1。
  • 定义了一个辅助函数 executeTask(),用于执行任务数组中的任务。该函数会遍历任务数组,对于非空的任务函数指针,调用对应的任务函数。
  • 定义了一个辅助函数 worker(),用于在子进程中执行具体的工作。该函数会打印进程的 ID(使用 getpid() 函数)和计数值。

在 main() 函数中:

  1. 声明了一个任务数组 tasks[TASK_NUM],并通过调用 initTasks() 初始化该数组。
  2. 调用 addTask() 函数将三个任务函数 download()、printLog() 和 show() 添加到任务数组中。
  3. 调用 fork() 创建一个子进程。如果返回值为 0,则表示当前代码在子进程中执行,否则表示在父进程中执行。
  4. 在子进程中,通过一个循环调用 worker() 函数执行具体的工作。每次循环都会打印进程的 ID 和计数值,并使用 sleep(2) 函数暂停 2 秒,然后将计数值减 1,直到计数值为 0。
  5. 在子进程的循环结束后,调用 exit(0) 终止子进程。
  6. 在父进程中,通过一个无限循环调用 waitpid() 函数来等待子进程的退出。waitpid() 函数用于等待指定的子进程结束,并获取子进程的退出状态。
  7. 使用 WNOHANG 选项,使得 waitpid() 在没有子进程退出时立即返回。这样可以让父进程在等待期间执行其他任务。
  8. **如果 waitpid() 返回值大于 0,则表示成功等待到一个子进程退出。**此时打印子进程的退出状态信息,并终止父进程的循环。
  9. 如果 waitpid() 返回值等于 0,则表示当前没有子进程退出,继续执行父进程的其他任务。在这里,调用 executeTask() 函数执行任务数组中的任务,并打印一些信息。
  10. 如果 waitpid() 返回值小于 0,则表示等待失败,打印错误信息,并终止父进程的循环。
  11. 在父进程的循环中,使用 sleep(1) 函数暂停 1秒,以降低循环的频率。

总体来说,这段代码创建了一个子进程,并在父进程中等待子进程的退出。在等待子进程退出的过程中,父进程会执行一些其他任务,并定期执行任务数组中的任务函数。子进程通过循环执行具体的工作,并在完成后退出。在子进程退出后,父进程打印子进程的退出状态信息,并终止循环,结束程序的执行。

相关文章
|
7月前
|
Linux C++
LInux下Posix的传统线程示例
LInux下Posix的传统线程示例
51 1
|
7月前
|
Linux
【Linux】—— 进程等待 wait&&waitpid
【Linux】—— 进程等待 wait&&waitpid
140 0
【Linux】—— 进程等待 wait&&waitpid
|
7月前
|
Linux Shell
【Linux】详解进程终止&&进程等待
【Linux】详解进程终止&&进程等待
|
7月前
|
安全 Linux 网络安全
Linux使用HTTP隧道代理代码示例模版
Linux使用HTTP隧道代理代码示例模版
92 0
|
7月前
|
Linux
进程等待(wait和wait函数)【Linux】
进程等待(wait和wait函数)【Linux】
121 0
|
2月前
|
Unix Linux
Linux | Rsync 命令:16 个实际示例(下)
Linux | Rsync 命令:16 个实际示例(下)
38 3
Linux | Rsync 命令:16 个实际示例(下)
|
2月前
|
安全 Linux Shell
Linux | Rsync 命令:16 个实际示例(上)
Linux | Rsync 命令:16 个实际示例(上)
74 0
Linux | Rsync 命令:16 个实际示例(上)
|
7月前
|
存储 Linux Shell
Linux:进程等待 & 进程替换
Linux:进程等待 & 进程替换
65 9
|
3月前
|
Linux Shell
Linux 中 Tail 命令的 9 个实用示例
Linux 中 Tail 命令的 9 个实用示例
108 6
Linux 中 Tail 命令的 9 个实用示例
|
4月前
|
存储 Linux
【linux】【系统】启动参数配置的示例
【linux】【系统】启动参数配置的示例
42 0