Потоки и асинхронность

void connect_handler(const boost::system::error_code & ec)
{
    // here we know we connected successfully
    // if ec indicates success 
}
 
 
int main()
{
    using boost::asio;
    io_service service;
    ip::tcp::endpoint ep( ip::address::from_string("127.0.0.1"), 2001);
    ip::tcp::socket sock(service);
 
    // вызов не блокирующий. 
    // то есть, здесь поток не ждет полного завершения процедуры "подключения"
    sock.async_connect(ep, connect_handler);
 
    // а сразу продолжает выполнение дальше
 
    service.run();
    ... // здесь делаем что хотим
}

#define _WIN32_WINNT 0x0501
    
#include <boost/asio/io_service.hpp>
#include <boost/thread/thread.hpp>
#include <boost/bind.hpp>
 
// функция, которая должна исполнять какую либо задачу.
// для примера пусть просто выводит текст в консоль
void myTask(const char* msg)
{
    std::cout << msg << '\n';
}
 
int main()
{
//-------------------------------------------------------------------
    // --- функциональность тред-пула
    
    boost::asio::io_service ioService;
    boost::thread_group threadpool;
    boost::asio::io_service::work work(ioService);
 
    // забиваем пулл рабочими тредами
    // обычно - по количеству ядер процессора
    const auto cpu_count 
        = boost::thread::hardware_concurrency();
 
    for(size_t n = 0; n!=cpu_count; ++n)
        threadpool.create_thread(
            boost::bind(&boost::asio::io_service::run, &ioService)
        );
//-------------------------------------------------------------------
    
    // нагружаем тред задачами
    for(size_t n = 0; n!=10;++n)
        ioService.post(boost::bind(myTask, "Hello World!"));
 
    // останавливаем пулл
    ioService.stop();
    
    // ждем когда все треды остановятся
    threadpool.join_all();    
}

boost::asio::thread_pool pool(4);