我已经改编了step 3 of the Boost asio tutorial永远运行，并每秒显示一次“tick”和“tock”而不是计数器:

#include <iostream>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>

void print(const boost::system::error_code& /*e*/,
    boost::asio::deadline_timer* t, int* count)
{
    if( !((*count) % 2) )
        std::cout << "tick\n";
    else
        std::cout << "tock\n";

    ++(*count);

    t->expires_at(t->expires_at() + boost::posix_time::seconds(1));
    t->async_wait(boost::bind(print,
          boost::asio::placeholders::error, t, count));
}

int main()
{
  boost::asio::io_service io;

  int count = 0;
  boost::asio::deadline_timer t(io, boost::posix_time::seconds(1));
  t.async_wait(boost::bind(print,
        boost::asio::placeholders::error, &t, &count));

  io.run();

  std::cout << "Final count is " << count << "\n";

  return 0;
}

现在我希望能够异步处理标准输入上的按键。是否有一个 io_service 处理程序可以用来响应按键，而不会阻塞 sleep 或等待？

例如，我希望能够实现类似于以下的处理函数:

void handle_keypress(const boost::error_code&,
    char c)
{
    std::cout << "Tap '" << c << "'\n";
}

我希望我对这个处理程序的调用是这样的:

  char c = 0;
  boost::asio::stdin_receiver sr(io);
  st.async_wait(boost::bind(handle_keypress, boost::asio::placeholders::error, &c));

  io.run();

这是我可以用 asio 做的事情吗，要么使用内置服务处理程序，要么编写我自己的？

编辑，详细说明:

我看过this question ，但是接受答案中的链接代码只是在 main 中执行此操作:

 while (std::cin.getline(

我正在编写的应用程序不是上面概述的这个简单的 tick-tock-tap gizmo，而是一个多播服务器。多个工作线程将向多播组发送数据包，响应来自主线程的消息，并将消息发送回主线程。反过来，应用程序将由来自 stdin 的输入“驱动”——例如，当用户按下“P”键时，多播广播将暂停，而当按下“Q”时，整个事情将关闭.在主线程中，我为响应这些输入所做的一切就是向工作线程发送消息。

上面的 while 循环在我的场景中不起作用，因为当它等待用户的 stdin 输入时，主线程将无法处理来自工作线程的消息。来自工作线程的一些消息将生成输出到标准输出。

最佳答案

我不相信posix chat client使用 while 循环或调用 std::getline，这是您在我之前的回答中链接到的示例代码。也许你指的是另一个例子？在任何情况下，您都不需要使用 io_service::dispatch 甚至一个单独的线程。流描述符的内置工具在这里工作得很好。参见 my previous answer类似的问题:使用 posix::stream_descriptor 并将 STDIN_FILENO 分配给它。使用 async_read 并在读取处理程序中处理请求。

我已经用一种方法修改了你的示例代码来完成这个

#include <iostream>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/enable_shared_from_this.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>

void print(const boost::system::error_code& /*e*/,
    boost::asio::deadline_timer* t, int* count)
{
    if( !((*count) % 2) )
        std::cout << "tick\n";
    else
        std::cout << "tock\n";

    ++(*count);

    t->expires_at(t->expires_at() + boost::posix_time::seconds(1));
    t->async_wait(boost::bind(print,
          boost::asio::placeholders::error, t, count));
}

class Input : public boost::enable_shared_from_this<Input>
{
public:
    typedef boost::shared_ptr<Input> Ptr;

public:
    static void create(
            boost::asio::io_service& io_service
            )
    {
        Ptr input(
                new Input( io_service )
                );
        input->read();
    }

private:
    explicit Input(
            boost::asio::io_service& io_service
         ) :
        _input( io_service )
    {
        _input.assign( STDIN_FILENO );
    }

    void read()
    {
        boost::asio::async_read(
                _input,
                boost::asio::buffer( &_command, sizeof(_command) ),
                boost::bind(
                    &Input::read_handler,
                    shared_from_this(),
                    boost::asio::placeholders::error,
                    boost::asio::placeholders::bytes_transferred
                    )
                );
    }

    void read_handler(
            const boost::system::error_code& error,
            const size_t bytes_transferred
            )
    {
        if ( error ) {
            std::cerr << "read error: " << boost::system::system_error(error).what() << std::endl;
            return;
        }

        if ( _command != '\n' ) {
            std::cout << "command: " << _command << std::endl;
        }

        this->read();
    }

private:
    boost::asio::posix::stream_descriptor _input;
    char _command;
};

int main()
{
  boost::asio::io_service io;

  int count = 0;
  boost::asio::deadline_timer t(io, boost::posix_time::seconds(1));
  t.async_wait(boost::bind(print,
        boost::asio::placeholders::error, &t, &count));

  Input::create( io);

  io.run();

  std::cout << "Final count is " << count << "\n";

  return 0;
}

编译、链接和运行

samm:stackoverflow samm$ g++ -I /opt/local/include stdin.cc -L /opt/local/lib -lboost_system -Wl,-rpath,/opt/local/lib
samm:stackoverflow samm$ echo "hello world" | ./a.out
command: h
command: e
command: l
command: l
command: o
command:  
command: w
command: o
command: r
command: l
command: d
read error: End of file
tick
tock
tick
tock
tick
tock
tick
tock
tick
tock
^C
samm:stackoverflow samm$

关于c++ - 标准输入按键的 asio 服务处理程序，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/10934444/