Boost ::按ID处理子项 [英] Boost::process child by id

问题描述

如何在on_exit函数中获取child.id()?

How I can get child.id() in on_exit function?

bp::child c(args, ios, bp::on_exit([&](int e, std::error_code ec) {
            result = e;
            ios.stop();
            //need c.id();    

        }));

或者如果孩子正在通过id运行，如何检查其他功能?

or how I can check in other function if the child is running by id?

        boost::process::child c(data->id); // doesn't work
        if (!c.running()) {
}

推荐答案

您可以将所需的任何其他信息绑定到处理程序.例如，您可以声明处理程序以引用 child 实例:

You can bind whatever extra information you want to your handler. For example, you can declare your handler to take a reference to the child instance:

static void exit_handler(bp::child& process, int e, std::error_code ec) {
    std::cout << "Process " << process.id() << " exited with " << e << " (" << ec.message() << ")\n";
}

现在，您可以使用 std :: bind (当然您可以使用lambda来完成工作)将其绑定到 on_exit 处理程序:

Now, you can bind that to the on_exit handler using std::bind (of course you can use a lambda to do the job):

p = bp::child(
        sv{"/bin/bash", "-c", command.str()},
        bp::on_exit(std::bind(exit_handler, std::ref(p), _1, _2)),
        io);

// Or, using a lambda to capture the reference:
p = bp::child(
        sv{"/bin/bash", "-c", command.str()},
        bp::on_exit([&p](int e, std::error_code ec) { exit_handler(p, e, ec); }),
        io);

一个完整的示例，它产生了11个子进程，这些子进程花费了不同的时间<1s完成并全部绑定到同一个处理程序:

A full example that spawns 11 child processes that take varying time < 1s to complete and all bind to the same handler:

在Coliru上直播

Live On Coliru

#include <boost/process.hpp>
#include <boost/process/async.hpp>
#include <iostream>
#include <functional> // std::bind & placeholders
#include <sstream>    // ostringstream

namespace bp = boost::process;
using namespace std::placeholders;
using sv = std::vector<std::string>;

static void exit_handler(bp::child& process, int e, std::error_code ec) {
    std::cout << "Process " << process.id() << " exited with " << e << " (" << ec.message() << ")\n";
}

int main() {
    boost::asio::io_context io;
    auto work = make_work_guard(io);

    std::list<bp::child> children;

    for (auto ch = 'a'; ch < 'k'; ++ch) {
        auto& p = children.emplace_back();
        std::ostringstream command;
        command << "echo 'hello from " << ch << "';";
        command << "sleep 0.$RANDOM;";
        command << "echo 'bye from " << ch << "';";
        command << "exit " << (rand()%42) << ";";

        p = bp::child(
                sv{"/bin/bash", "-c", command.str()},
                bp::on_exit(std::bind(exit_handler, std::ref(p), _1, _2)),
                io);
    }

    work.reset(); // allow io to be finished
    io.run();     // wait for that

    std::cout << "Bye\n";
}

打印:

hello from b
hello from a
hello from c
hello from d
hello from e
hello from f
hello from g
hello from i
hello from h
hello from j
bye from g
bye from a
bye from h
bye from b
bye from d
bye from f
bye from j
bye from e
bye from i
bye from c
Process 12044 exited with 10 (Success)
Process 12034 exited with 1 (Success)
Process 12047 exited with 30 (Success)
Process 12035 exited with 4 (Success)
Process 12038 exited with 19 (Success)
Process 12043 exited with 31 (Success)
Process 12050 exited with 31 (Success)
Process 12042 exited with 29 (Success)
Process 12049 exited with 15 (Success)
Process 12036 exited with 9 (Success)
Bye

更新

为了也能够查询哪个子代仍在运行，请考虑使用 map 而不是 list (请谨慎选择容器的参考稳定性！)

UPDATE

To also be able to query which child is still running, consider using a map instead of a list (be very careful about reference stability of your container choice!).

这是一个演示 在Coliru上直播

std::map<char, bp::child> children;

for (char name = 'a'; name < 'k'; ++name) {
    std::ostringstream command;
    command << "echo 'hello from " << name << "';";
    command << "sleep " << (rand()%900 + 101)/1000.0 << ";";
    command << "echo 'bye from " << name << "';";
    command << "exit " << (rand()%42) << ";";

    auto& p = children[name];
    p = bp::child(
            sv{"/bin/sh", "-c", command.str()},
            bp::on_exit(std::bind(exit_handler, std::ref(p), _1, _2)),
            io);
}

work.reset(); // allow io to be finished

while (io.run_one()) { // wait for that
    std::cout << "Still running: ";
    for (auto& [name, child] : children) {
        if (child.running())
            std::cout << " " << name;
    }
    std::cout << std::endl;
}

std::cout << "Bye\n";

打印

hello from a
hello from b
hello from c
hello from d
hello from e
hello from f
hello from g
hello from h
hello from i
Still running:  a b c d e f g h i j
Still running:  a b c d e f g h i j
hello from j
bye from i
Still running:  a b c d e f g h j
Process 30748 exited with -1
Still running:  a b c d e f g h j
bye from e
Still running:  a b c d f g h j
Still running:  a b c d f g h j
Process 30739 exited with -1
Still running:  a b c d f g h j
bye from c
Still running:  a b d f g h j
Still running:  a b d f g h j
Process 30735 exited with -1
Still running:  a b d f g h j
bye from b
Still running:  a d f g h j
Still running:  a d f g h j
Process 30733 exited with -1
Still running:  a d f g h j
bye from h
Still running:  a d f g j
Still running:  a d f g j
Process 30744 exited with -1
Still running:  a d f g j
bye from d
Still running:  a f g j
Still running:  a f g j
Process 30737 exited with -1
Still running:  a f g j
bye from g
Still running:  a f j
Still running:  a f j
Process 30743 exited with -1
Still running:  a f j
bye from f
Still running:  a j
Still running:  a j
Process 30740 exited with -1
Still running:  a j
bye from j
Still running:  a
Still running:  a
Process 30749 exited with -1
Still running:  a
bye from a
Still running: 
Still running: 
Process 30732 exited with -1
Still running: 
Bye

这篇关于Boost ::按ID处理子项的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！