boost asio 정리 - 5 (work 고찰)

1. 목적

이제 마무리 단계에 왔다. 바로 work의 사용법이다. work는 io_service start 전에 post()에 기술된 handler함수가 먼저 종료되는 상황에서 io_service start를 차 후에 호출하더라도 실제 post의 핸들러 함수는 돌지 않는다. 이를 방지 하기 위해서 항상 block되어 돌도록 하기 위해서 사용한다.

2. 코드 설명

아래 코드에서 현재 상태로 코드를 돌리면 아무 동작을 하지 않는다. 비동기 동작과 유사한 동작을 위해서 post에 전달하는 방식을 thread로 변경하였다. 이 부분이 앞의 예제와 변경된 사항이다.

#include <iostream> #include <boost/asio.hpp> #include <boost/smart_ptr.hpp> #include <boost/bind.hpp> #include <boost/thread.hpp> #include <boost/chrono.hpp> #include <boost/thread/scoped_thread.hpp> #include <boost/lexical_cast.hpp> class CTest { public : CTest() : service(), strand(service) //CTest() : service(), strand(service), work(service) { std::cout << __FUNCTION__ << std::endl; } virtual ~CTest() { std::cout << __FUNCTION__ << std::endl; } void do_print(int x) { boost::function<void(int)> handler = [&](int x) { std::string curTrId = boost::lexical_cast<std::string>(boost::this_thread::get_id()); for(int i = 0; i < x; i++) { std::printf("[ %d -> current Thread Id : %s] \n", i, curTrId.c_str()); boost::this_thread::sleep_for(boost::chrono::milliseconds(100)); } }; service.post(strand.wrap(boost::bind(handler, x))); } void start(void) { std::cout << __FUNCTION__ << ", " << __LINE__ << std::endl; for(int i = 0; i < 2; i++) { print_threads.create_thread(boost::bind(&CTest::do_print, this, 100)); } for(int i = 0; i < 2; i++) { io_threads.create_thread(boost::bind(&boost::asio::io_service::run, &service)); } } void stop(void) { service.stop(); print_threads.join_all(); io_threads.join_all(); service.reset(); } private : boost::asio::io_service service; //boost::asio::io_service::work work; boost::asio::io_service::strand strand; boost::thread_group io_threads; boost::thread_group print_threads; }; int main(int argc, char* argv[]) { CTest test; test.start(); while(1) { char option; std::cout << "... in while loop ..." << std::endl; std::cin.get(option); if(option == 'x') { break; } } test.stop(); std::cout << "... end of main ..." << std::endl; return 0; }

3. 정리

주석 처리된 부분을 풀고 빌드해서 실행해 보면 정상적으로 동작한다. 이것으로 boost asio 기본 API 함수들의 동작에 대해서 알아보았다. 이제 Network이나 Timer의 동작을 좀 더 명확하게 이해할 수 있는 기반을 갖췄다고 개인적으로 생각이 듭니다.