Читать дочерний процесс stdout в отдельном потоке с процессом BOOST

У меня есть основная программа, которая использует библиотеку процессов повышения, чтобы порождать дочерний процесс, который печатает

Hello World !

на его стандартный выход каждые 5 секунд.

Я хотел бы читать / отслеживать стандартный вывод дочернего процесса в основном процессе, когда он становится доступным наряду с выполнением других операций в основной программе.

Я опробовал примеры для boost asynchronous IO (http://www.boost.org/doc/libs/1_66_0/doc/html/boost_process/tutorial.html) но все это, кажется, блокирует основную программу, пока дочерний процесс не завершится.

Нужно ли читать дочерний вывод в отдельной теме? Может кто-нибудь привести пример, когда основная программа может выполнять другие действия одновременно, вместо того, чтобы блокировать стандартный вывод от ребенка?

1

Решение

Я опробовал примеры для повышения асинхронного ввода-вывода (http://www.boost.org/doc/libs/1_66_0/doc/html/boost_process/tutorial.html) но все это, кажется, блокирует основную программу, пока дочерний процесс не завершится.

Посмотри снова. Все образцы под Асинхронный ввод / вывод должен помочь вам выбрать метод, который работает для вас.

Нужно ли читать дочерний вывод в отдельной теме? Может кто-нибудь привести пример, когда основная программа может выполнять другие действия одновременно, вместо того, чтобы блокировать стандартный вывод от ребенка?

Нет не необходимость к. Хоть ты Можно и в зависимости от того, чего вы пытаетесь достичь, это может быть проще всего.

синхронный

Вы не сообщили нам, что хотите сделать, поэтому предположим, что вы просто хотите напечатать вывод:

Жить на Колиру:

bp::child c("/bin/bash", std::vector<std::string> { "-c", "for a in {1..10}; do sleep 2; echo 'Hello World !'; done" });
c.wait();

Это синхронно, так что вы не можете делать работу в то же время

Использование темы чтения

Это как:

Жить на Колиру:

#include <boost/process.hpp>
#include <boost/process/async.hpp>
#include <iostream>

namespace bp = boost::process;

int main() {
bp::ipstream output;
std::thread reader([&output] {
std::string line;
while (std::getline(output, line))
std::cout << "Received: '" << line << "'" << std::endl;
});

bp::child c("/bin/bash",
std::vector<std::string> { "-c", "for a in {1..10}; do sleep 2; echo 'Hello World ('$a')!'; done" },
bp::std_out > output);

while (c.running()) {
std::this_thread::sleep_for(std::chrono::milliseconds(2793));
std::cout << "(main thread working)" << std::endl;
}

std::cout << "(done)" << std::endl;
c.wait();

output.pipe().close();
reader.join();
}

Принты (Жить на Колиру):

Received: 'Hello World (1)!'
(main thread working)
Received: 'Hello World (2)!'
(main thread working)
Received: 'Hello World (3)!'
Received: 'Hello World (4)!'
(main thread working)
Received: 'Hello World (5)!'
(main thread working)
Received: 'Hello World (6)!'
(main thread working)
Received: 'Hello World (7)!'
Received: 'Hello World (8)!'
(main thread working)
Received: 'Hello World (9)!'
(main thread working)
Received: 'Hello World (10)!'
(main thread working)
(done)

Асинхронный ввод-вывод

Без использования потоков (ну, только основной поток), может выглядеть так:

Жить на Колиру

#include <boost/process.hpp>
#include <boost/process/async.hpp>
#include <boost/asio/high_resolution_timer.hpp>
#include <iostream>
#include <iomanip>

namespace bp = boost::process;

struct OtherWork {
using clock = std::chrono::high_resolution_clock;

OtherWork(boost::asio::io_context& io) : timer(io) { }

void start() {
timer.expires_at(clock::time_point::max());
loop();
}

void stop() {
timer.expires_at(clock::time_point::min());
}

private:
void loop() {
if (timer.expires_at() == clock::time_point::min()) {
std::cout << "(done)" << std::endl;
return;
}

timer.expires_from_now(std::chrono::milliseconds(2793));
timer.async_wait([=](boost::system::error_code ec) {
if (!ec) {
std::cout << "(other work in progress)" << std::endl;
start();
} else {
std::cout << "(" << ec.message() << ")" << std::endl;
}
});
}

boost::asio::high_resolution_timer timer;
};

int main() {
boost::asio::io_context io;
bp::async_pipe output(io);

OtherWork mainwork{io};

bp::child c("/bin/bash", std::vector<std::string> { "-c", "for a in {1..10}; do sleep 2; echo 'Hello World ('$a')!'; done" },
bp::std_out > output, io, bp::on_exit([&mainwork,&output](auto...) {
output.close();
mainwork.stop();
}));

std::function<void()> readloop = [&,buffer=std::array<char, 32>{}]() mutable {
output.async_read_some(bp::buffer(buffer), [&](boost::system::error_code ec, size_t transferred) {
if (transferred) {
std::cout << "Received: '";
while (transferred && buffer[transferred-1] == '\n') // strip newline(s)
--transferred;
std::cout.write(buffer.data(), transferred);
std::cout << "'" << std::endl;
}

if (ec)
std::cout << "Output pipe: " << ec.message() << std::endl;
else
readloop();
});
};

mainwork.start();
readloop();
io.run();
}

Печать Жить на Колиру

Received: 'Hello World (1)!'
(other work in progress)
Received: 'Hello World (2)!'
(other work in progress)
Received: 'Hello World (3)!'
Received: 'Hello World (4)!'
(other work in progress)
Received: 'Hello World (5)!'
(other work in progress)
Received: 'Hello World (6)!'
(other work in progress)
Received: 'Hello World (7)!'
Received: 'Hello World (8)!'
(other work in progress)
Received: 'Hello World (9)!'
(other work in progress)
Received: 'Hello World (10)!'
Output pipe: End of file
Child exited with code=0(Success)
(Operation canceled)
4

Другие решения

Других решений пока нет …

По вопросам рекламы ammmcru@yandex.ru
Adblock
detector