c++ - 在程序中执行一个或多个新进程

Question

我想知道从正在运行的进程中执行新进程(程序)的最佳实践是什么。更具体地说，我正在实现一个 C/C++ 作业调度程序，它必须在与多个二进制文件通信时运行它们。 exec 或 fork 常见吗？或者有没有图书馆负责这个？

Answer 1

您可以使用 popen() 生成进程并与它们通信。为了处理来自单个父进程的多个进程的通信，使用 select() 或 poll() 来复用给你的文件描述符的读/写popen()(您可以使用 fileno() 将 FILE* 转换为整数文件描述符)。

如果你想要一个库为你抽象其中的大部分内容，我建议使用 libuv。这是我创建的一个完整的示例程序，主要遵循 https://nikhilm.github.io/uvbook/processes.html#spawning-child-processes 上的文档。 :

#include <cstdio>
#include <cstdlib>
#include <inttypes.h>
#include <uv.h>

static void alloc_buffer(uv_handle_t *handle, size_t suggested_size, uv_buf_t *buf)
{
    *buf = uv_buf_init((char*)malloc(suggested_size), suggested_size);
}

void echo_read(uv_stream_t *server, ssize_t nread, const uv_buf_t* buf)
{
    if (nread == -1) {
        fprintf(stderr, "error echo_read");
        return;
    }

    puts(buf->base);
}

static void on_exit(uv_process_t *req, int64_t exit_status, int term_signal)
{
    fprintf(stderr, "Process %d exited with status %" PRId64 ", signal %d\n",
            req->pid, exit_status, term_signal);
    uv_close((uv_handle_t*)req, NULL);
}

int main()
{
    uv_loop_t* loop = uv_default_loop();
    const int N = 3;
    uv_pipe_t channel[N];
    uv_process_t child_req[N];

    for (int ii = 0; ii < N; ++ii) {
        char* args[3];
        args[0] = const_cast<char*>("ls");
        args[1] = const_cast<char*>(".");
        args[2] = NULL;

        uv_pipe_init(loop, &channel[ii], 1);

        uv_stdio_container_t child_stdio[3]; // {stdin, stdout, stderr}                                                 
        child_stdio[STDIN_FILENO].flags = UV_IGNORE;
        child_stdio[STDOUT_FILENO].flags = uv_stdio_flags(UV_CREATE_PIPE | UV_WRITABLE_PIPE);
        child_stdio[STDOUT_FILENO].data.stream = (uv_stream_t*)&channel[ii];
        child_stdio[STDERR_FILENO].flags = UV_IGNORE;

        uv_process_options_t options = {};
        options.exit_cb = on_exit;
        options.file = "ls";
        options.args = args;
        options.stdio = child_stdio;
        options.stdio_count = sizeof(child_stdio) / sizeof(child_stdio[0]);

        int r;
        if ((r = uv_spawn(loop, &child_req[ii], &options))) {
            fprintf(stderr, "%s\n", uv_strerror(r));
            return EXIT_FAILURE;
        } else {
            fprintf(stderr, "Launched process with ID %d\n", child_req[ii].pid);
            uv_read_start((uv_stream_t*)&channel[ii], alloc_buffer, echo_read);
        }
    }

    return uv_run(loop, UV_RUN_DEFAULT);
}

上面的代码会生成三个 ls 拷贝来打印当前目录的内容。它们都是异步运行的。