Сокеты, одновременная работа с несколькими клиентами !!!

#include <iostream>
#include <boost/asio.hpp>
 
using namespace std;
 
int main()
{
    cout << "Hello world!" << endl;
    return 0;
}

#include <iostream>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/shared_array.hpp>
#include <boost/thread.hpp>
 
/***************************************************************************/
 
// максимальная длина принимаемого сообщения.
static const size_t message_len = 10000;
 
typedef boost::shared_ptr<boost::asio::ip::tcp::socket> socket_ptr;
 
// начало приема запросов на подключение.
void start_accept(
   boost::asio::ip::tcp::acceptor* acceptor
);
 
// создаем асинхронную операцию аксепта.
void on_accept(
   boost::asio::ip::tcp::acceptor* acceptor,
   socket_ptr socket
);
 
// вызовется при подключении.
void on_accept_handler(
   boost::asio::ip::tcp::acceptor* acceptor,
   socket_ptr socket,
   const boost::system::error_code& error // объект ошибки
);
 
// вызовется при завершении асинхронной записи.
void on_async_read(
   socket_ptr socket,
   boost::shared_array<char> message, // shared_array мы сюда передаем для
                                      // того, чтоб не дать ему удалить данные которыми он
                                      // владеет до завершения асинхронной записи.
   const boost::system::error_code& error // объект ошибки
);
 
void on_async_write(
  const boost::system::error_code& error,
  std::size_t bytes_transferred
);
 
 
/***************************************************************************/
 
int main() {
   static const char* ip = "127.0.0.1";
   static const boost::uint16_t port = 44550;
 
   // io_service - основа asio.
   boost::asio::io_service ios;
 
   // объект реализующий "вечную задачу".
   boost::shared_ptr<boost::asio::io_service::work> work(new boost::asio::io_service::work(ios));
 
   // определяем кол-во ядер.
   size_t cpu_count = boost::thread::hardware_concurrency();
 
   // создаем кол-во рабочих потоков равное кол-ву ядер.
   boost::thread_group work_threads;
   for ( size_t idx = 0; idx < cpu_count; ++idx ) {
      work_threads.create_thread(boost::bind(&boost::asio::io_service::run, &ios));
   }
 
   // объект представляющий адрес для TCP соединений.
   boost::asio::ip::tcp::endpoint endpoint(boost::asio::ip::address::from_string(ip), port);
 
   // объект акксептора соединений.
   boost::asio::ip::tcp::acceptor acceptor(ios, endpoint);
 
   // запускаем асинхронный прием запросов на подключение
   start_accept(&acceptor);
 
   // сбрасываем "вечную задачу".
   work.reset();
 
   // работаем пока не завершаться все потоки.
   work_threads.join_all();
 
   // завершаемся.
   return 0;
}
 
/***************************************************************************/
 
// создаем асинхронную операцию аксепта
void start_accept(
   boost::asio::ip::tcp::acceptor* acceptor)
{
   // создаем объект сокета который будет связан с принятым подключением.
   socket_ptr socket(new socket_ptr::element_type(acceptor->get_io_service()));
 
   // создаем операци. асинхронного аксепта.
   acceptor->async_accept(
      *socket,
      boost::bind(
         &on_accept_handler,
         acceptor,
         socket,
         boost::asio::placeholders::error
      )
   );
}
 
// вызовется при приеме нового подключения.
void on_accept_handler(
   boost::asio::ip::tcp::acceptor* acceptor,
   socket_ptr socket,
   const boost::system::error_code& error)
{
   if ( !error ) {
      // создаем shared_array который должен жить вплоть до окончании асинхронного чтения.
      // для этого, message передаем как аргумент в функциональный объект, для того, чтоб инкрементировать счетчик ссылок.
      boost::shared_array<char> message(new char[message_len]);
 
      // для принятого соединения запускаем операцию асинхронного чтения.
      boost::asio::async_read(
         *socket,
         boost::asio::buffer(message.get(), message_len),
         boost::asio::transfer_at_least(2),
         boost::bind(
            &on_async_read,
            socket,
            message,
            boost::asio::placeholders::error
         )
      );
   } else {
      std::cout << "on_accept_handler() error: " << error.message() << std::endl;
   }
 
   // снова запускаем асинхронный прием запросов на подключение
   start_accept(acceptor);
}
 
/***************************************************************************/
 
// вызовется при завершении асинхронного чтения.
 
// примечание: аргумент message и socket, разрушаться при выходе из функции.
void on_async_read(
   socket_ptr socket,
   boost::shared_array<char> message,
   const boost::system::error_code& error)
{
   if ( !error ) {
      std::cout << "received message: " << message.get() << std::endl;
 
       char answer[10] = "ALL OK!!!";
       int g = 500;
       for (int i=0; i<2000000000; i++) {
            g=g*g;
            g=g*g;
            g=g*g;
       }
 
       boost::asio::async_write(
         *socket,
         boost::asio::buffer(answer, 10),
         on_async_write
      );
 
 
   } else {
      std::cout << "on_async_read() error: " << error.message() << std::endl;
   }
}
 
 
void on_async_write(const boost::system::error_code& error, std::size_t bytes_transferred) {
 
///
 
};
 
/***************************************************************************/

#include <iostream>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/shared_array.hpp>
#include <boost/thread.hpp>
 
/***************************************************************************/
 
// максимальная длина принимаемого сообщения.
static const size_t message_len = 32;
 
typedef boost::shared_ptr<boost::asio::ip::tcp::socket> socket_ptr;
 
// начало приема запросов на подключение.
void start_accept(
   boost::asio::ip::tcp::acceptor* acceptor
);
 
// вызовется при подключении.
void on_accept_handler(
   boost::asio::ip::tcp::acceptor* acceptor,
   socket_ptr socket,
   const boost::system::error_code& error // объект ошибки
);
 
// вызовется при завершении асинхронной записи.
void on_async_read(
   socket_ptr socket,
   boost::shared_array<char> message, // shared_array мы сюда передаем для
                                      // того, чтоб не дать ему удалить данные которыми он
                                      // владеет до завершения асинхронной записи.
   const boost::system::error_code& error, // объект ошибки
   std::size_t bytes_transferred
);
 
void on_async_write(
   socket_ptr socket,
   const boost::system::error_code& error,
   std::size_t bytes_transferred
);
 
/***************************************************************************/
 
int main() {
   static const char* ip = "127.0.0.1";
   static const boost::uint16_t port = 44550;
 
   // io_service - основа asio.
   boost::asio::io_service ios;
 
   // объект реализующий "вечную задачу".
   boost::shared_ptr<boost::asio::io_service::work> work(new boost::asio::io_service::work(ios));
 
   // определяем кол-во ядер.
   //size_t cpu_count = boost::thread::hardware_concurrency();
   size_t cpu_count = 2;
 
   // создаем кол-во рабочих потоков равное кол-ву ядер.
   boost::thread_group work_threads;
   for ( size_t idx = 0; idx < cpu_count; ++idx ) {
      work_threads.create_thread(boost::bind(&boost::asio::io_service::run, &ios));
   }
 
   // объект представляющий адрес для TCP соединений.
   boost::asio::ip::tcp::endpoint endpoint(boost::asio::ip::address::from_string(ip), port);
 
   // объект акксептора соединений.
   boost::asio::ip::tcp::acceptor acceptor(ios, endpoint);
 
   // запускаем асинхронный прием запросов на подключение
   start_accept(&acceptor);
 
   // сбрасываем "вечную задачу".
   work.reset();
 
   // работаем пока не завершаться все потоки.
   work_threads.join_all();
 
   // завершаемся.
   return 0;
}
 
/***************************************************************************/
 
// создаем асинхронную операцию аксепта
void start_accept(
   boost::asio::ip::tcp::acceptor* acceptor)
{
   // создаем объект сокета который будет связан с принятым подключением.
   socket_ptr socket(new socket_ptr::element_type(acceptor->get_io_service()));
 
   // создаем операци. асинхронного аксепта.
   acceptor->async_accept(
      *socket,
      boost::bind(
         &on_accept_handler,
         acceptor,
         socket,
         boost::asio::placeholders::error
      )
   );
}
 
// вызовется при приеме нового подключения.
void on_accept_handler(
   boost::asio::ip::tcp::acceptor* acceptor,
   socket_ptr socket,
   const boost::system::error_code& error)
{
   if ( !error ) {
      std::cout << "new connection from " << socket->remote_endpoint() << std::endl;
      // создаем shared_array который должен жить вплоть до окончании асинхронного чтения.
      // для этого, message передаем как аргумент в функциональный объект, для того, чтоб инкрементировать счетчик ссылок.
      boost::shared_array<char> message(new char[message_len]);
 
      // для принятого соединения запускаем операцию асинхронного чтения.
      boost::asio::async_read(
         *socket,
         boost::asio::buffer(message.get(), message_len),
         boost::asio::transfer_at_least(2),
         boost::bind(
            on_async_read,
            socket,
            message,
            boost::asio::placeholders::error,
            boost::asio::placeholders::bytes_transferred
         )
      );
   } else {
      std::cout << "on_accept_handler() error: " << error.message() << std::endl;
   }
 
   // снова запускаем асинхронный прием запросов на подключение
   start_accept(acceptor);
}
 
/***************************************************************************/
 
// вызовется при завершении асинхронного чтения.
 
// примечание: аргумент message и socket, разрушаться при выходе из функции.
void on_async_read(
   socket_ptr socket,
   boost::shared_array<char> message,
   const boost::system::error_code& error,
   std::size_t bytes_transferred)
{
   if ( !error ) {
      message[bytes_transferred] = 0;
      std::cout << "received message: " << message.get() << std::endl;
      sleep(10); // <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<
 
      boost::asio::async_write(
         *socket,
         boost::asio::buffer("reply!"),
         boost::bind(
            on_async_write,
            socket,
            boost::asio::placeholders::error,
            boost::asio::placeholders::bytes_transferred
         )
      );
 
   } else {
      std::cout << "on_async_read() error: " << error.message() << std::endl;
   }
}
 
/***************************************************************************/
 
void on_async_write(
   socket_ptr socket,
   const boost::system::error_code& error,
   std::size_t bytes_transferred)
{
   std::cout << "on_async_write(): e: " << error << ", writen: " << bytes_transferred << std::endl;
 
   boost::shared_array<char> message(new char[message_len]);
 
   // для принятого соединения запускаем операцию асинхронного чтения.
   boost::asio::async_read(
      *socket,
      boost::asio::buffer(message.get(), message_len),
      boost::asio::transfer_at_least(2),
      boost::bind(
         &on_async_read,
         socket,
         message,
         boost::asio::placeholders::error,
         boost::asio::placeholders::bytes_transferred
      )
   );
}
 
/***************************************************************************/

void on_async_write(
   socket_ptr socket,
   const boost::system::error_code& error,
   std::size_t bytes_transferred)
{
   std::cout << "on_async_write(): e: " << error << ", writen: " << bytes_transferred << std::endl;
 
   boost::shared_array<char> message(new char[message_len]);
 
   /*
   // для принятого соединения запускаем операцию асинхронного чтения.
   boost::asio::async_read(
      *socket,
      boost::asio::buffer(message.get(), message_len),
      boost::asio::transfer_at_least(2),
      boost::bind(
         &on_async_read,
         socket,
         message,
         boost::asio::placeholders::error,
         boost::asio::placeholders::bytes_transferred
      )
   );
   */
}