C++Boost – 第2页 – 九霄天空-IT技术分享学习

C++思维导图

2020年4月16日2020年4月17日
C++Boost, Code
680 clicked

boost中多线程下post与dispatch(转载)

2020年3月14日2020年3月15日
C++Boost, Code
551 clicked

为io_service添加任务，并且区分dispatch与post的区别.如果说io_service是asio库的大脑，那么post与dispatch就是asio库的手和脚。先看看示例1

#include <boost/asio.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/thread.hpp>
#include <boost/thread/mutex.hpp>
#include <boost/bind.hpp>
#include <iostream>

boost::mutex global_stream_lock;

void WorkerThread( boost::shared_ptr< boost::asio::io_service > io_service )
{
    global_stream_lock.lock();
    std::cout << "[" << boost::this_thread::get_id()
        << "] Thread Start" << std::endl;
    global_stream_lock.unlock();

    io_service->run();

    global_stream_lock.lock();
    std::cout << "[" << boost::this_thread::get_id()
        << "] Thread Finish" << std::endl;
    global_stream_lock.unlock();
}

size_t fib( size_t n )
{
    if ( n <= 1 )
    {
        return n;
    }
    boost::this_thread::sleep(
        boost::posix_time::milliseconds( 1000 )
        );
    return fib( n - 1 ) + fib( n - 2);
}

void CalculateFib( size_t n )
{
    global_stream_lock.lock();
    std::cout << "[" << boost::this_thread::get_id()
        << "] Now calculating fib( " << n << " ) " << std::endl;
    global_stream_lock.unlock();

    size_t f = fib( n );

    global_stream_lock.lock();
    std::cout << "[" << boost::this_thread::get_id()
        << "] fib( " << n << " ) = " << f << std::endl;
    global_stream_lock.unlock();
}

int main( int argc, char * argv[] )
{
    boost::shared_ptr< boost::asio::io_service > io_service(
        new boost::asio::io_service
        );
    boost::shared_ptr< boost::asio::io_service::work > work(
        new boost::asio::io_service::work( *io_service )
        );

    global_stream_lock.lock();
    std::cout << "[" << boost::this_thread::get_id()
        << "] The program will exit when all work has finished."
        << std::endl;
    global_stream_lock.unlock();

    boost::thread_group worker_threads;
    for( int x = 0; x < 2; ++x )
    {
        worker_threads.create_thread(
            boost::bind( &WorkerThread, io_service )
            );
    }

    io_service->post( boost::bind( CalculateFib, 3 ) );
    io_service->post( boost::bind( CalculateFib, 4 ) );
    io_service->post( boost::bind( CalculateFib, 5 ) );

    work.reset();

    worker_threads.join_all();

    return 0;
}

#include <boost/asio.hpp>

#include <boost/shared_ptr.hpp>

#include <boost/thread.hpp>

#include <boost/thread/mutex.hpp>

#include <boost/bind.hpp>

#include <iostream>

boost::mutex global_stream_lock;

void WorkerThread( boost::shared_ptr< boost::asio::io_service > io_service )

{

global_stream_lock.lock();

std::cout << "[" << boost::this_thread::get_id()

<< "] Thread Start" << std::endl;

global_stream_lock.unlock();

io_service->run();

global_stream_lock.lock();

std::cout << "[" << boost::this_thread::get_id()

<< "] Thread Finish" << std::endl;

global_stream_lock.unlock();

}

size_t fib( size_t n )

{

if ( n <= 1 )

{

return n;

}

boost::this_thread::sleep(

boost::posix_time::milliseconds( 1000 )

);

return fib( n - 1 ) + fib( n - 2);

}

void CalculateFib( size_t n )

{

global_stream_lock.lock();

std::cout << "[" << boost::this_thread::get_id()

<< "] Now calculating fib( " << n << " ) " << std::endl;

global_stream_lock.unlock();

size_t f = fib( n );

global_stream_lock.lock();

std::cout << "[" << boost::this_thread::get_id()

<< "] fib( " << n << " ) = " << f << std::endl;

global_stream_lock.unlock();

}

int main( int argc, char * argv[] )

{

boost::shared_ptr< boost::asio::io_service > io_service(

new boost::asio::io_service

);

boost::shared_ptr< boost::asio::io_service::work > work(

new boost::asio::io_service::work( *io_service )

);

global_stream_lock.lock();

std::cout << "[" << boost::this_thread::get_id()

<< "] The program will exit when all work has finished."

<< std::endl;

global_stream_lock.unlock();

boost::thread_group worker_threads;

for( int x = 0; x < 2; ++x )

{

worker_threads.create_thread(

boost::bind( &WorkerThread, io_service )

);

}

io_service->post( boost::bind( CalculateFib, 3 ) );

io_service->post( boost::bind( CalculateFib, 4 ) );

io_service->post( boost::bind( CalculateFib, 5 ) );

work.reset();

worker_threads.join_all();

return 0;

}

代码使用智能指针控制io_service，使用mutex控制各个进程间的… 阅读更多 »boost中多线程下post与dispatch(转载)

Boost.Asio的使用技巧(转载)

2020年3月14日2020年3月15日
C++Boost, Code
664 clicked

最近尝试使用了一下Boost.Asio，不知道是否因为各大公司都有自己相对成熟的网络库的缘故，网络上Asio相关的资料实在不多，而且很多翻来覆去就是那几个简单的示例，所以打算自己小结一下。总的来说Boost.Asio是个非常易用的库，避免了你在各种系统底层API之间的挣扎，让你可以非常迅速的开发出高并发的网络服务器程序。基… 阅读更多 »Boost.Asio的使用技巧(转载)

Boost_asio io_service 实现分析(转载)

2020年3月14日2020年3月15日
C++Boost, Code
483 clicked

io_service的作用 io_servie 实现了一个任务队列，这里的任务就是void(void)的函数。Io_servie最常用的两个接口是post和run，post向任务队列中投递任务，run是执行队列中的任务，直到全部执行完毕，并且run可以被N个线程调用。Io_service是完全线程安全的队列。 io_servie… 阅读更多 »Boost_asio io_service 实现分析(转载)