Boost::asio 并发性（？）

发布于 2024-11-19 05:14:23 字数 503 浏览 2 评论 0原文

我正在编译 boost::asio 示例： http://www.boost .org/doc/libs/1_46_1/doc/html/boost_asio/examples.html#boost_asio.examples.http_server_3

应该是一个多线程服务器实现。

现在，在 async_read 处理程序中，我打印一条消息并休眠 30 秒。我在两个浏览器中打开 localhost，看到handle_read被调用一次，然后30秒没有任何反应，最后handle_read被第二次调用。

使用 5 个线程调用 io_Service.run。

为什么处理程序没有同时调用？例如，为什么它要等待第一个handle_read完成后再调用第二个？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

遮云壑 2024-11-26 05:14:23

它有助于发布代码。当我对asio示例使用此修改时：

void connection::handle_read(const boost::system::error_code& e,
    std::size_t bytes_transferred)
{
  std::cerr << "connection::handle_read()\n";
  boost::this_thread::sleep(boost::posix_time::seconds(10));
  std::cerr << "connection::handle_read() done sleep\n";
  if (!e)
  {

它按预期工作，即

$ ./test 0.0.0.0 7777 5 .
connection::handle_read()
connection::handle_read()
connection::handle_read() done sleep
connection::handle_read() done sleep

How do you“sleep for 30秒”？也许您使用的 sleep 函数会暂停进程中的所有线程？

It helps to post code. When I use this modification to the asio example:

void connection::handle_read(const boost::system::error_code& e,
    std::size_t bytes_transferred)
{
  std::cerr << "connection::handle_read()\n";
  boost::this_thread::sleep(boost::posix_time::seconds(10));
  std::cerr << "connection::handle_read() done sleep\n";
  if (!e)
  {

it works as expected, that is

$ ./test 0.0.0.0 7777 5 .
connection::handle_read()
connection::handle_read()
connection::handle_read() done sleep
connection::handle_read() done sleep

How do you "sleep for 30 seconds"? Perhaps the sleep function you've used pauses all threads in the process?

回复收藏 0 原文

~没有更多了~