message queue - with boost lib

네가 만든 message queue를 boost library로 바꿔봤다.

boost 예제를 조금 수정했는데, boost는 process 대상이고 난 thread로 변경했을 뿐이다.

동작은 네가 만든 것과 동일하다. 단지 message queue 상태 검사는 없다. 

1. 소스트리

.

├── CMakeLists.txt

├── remove.sh

└── test.cpp

2. CMakeLists.txt 변경 사항.

cmake_minimum_required(VERSION 2.8) project(test) # add definition add_definitions(-std=c++0x) message(STATUS "CMAKE_SOURCE_DIR : " ${CMAKE_SOURCE_DIR}) message(STATUS "CMAKE_LIBRARY_PATH: " ${CMAKE_LIBRARY_PATH}) #set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -save-temps") # set variables set(BIN_NAME test) set(SRCS ${PROJECT_SOURCE_DIR}/test.cpp ) set(Boost_USE_STATIC_LIBS ON) set(Boost_USE_MULTITHREADED ON) #find_package(Boost REQUIRED) #find_package(Boost 1.54 REQUIRED system serialization) find_package(Boost 1.54.0 COMPONENTS thread system serialization log log_setup program_options REQUIRED) if (Boost_FOUND) include_directories(${Boost_INCLUDE_DIRS}) link_directories(${Boost_LIBRARY_DIRS}) # target_link_libraries( ${BIN_NAME} ${Boost_LIBRARIES}) endif (Boost_FOUND) # add include files include_directories(${CMAKE_CURRENT_SOURCE_DIR}) # create executable add_executable(${BIN_NAME} ${SRCS}) target_link_libraries(${BIN_NAME} rt pthread ${Boost_LIBRARIES} )

cmake에서 기본적으로 관리하는 package에서 찾아서 링크 시켰다.

참고로 pkg-config를 쓰려면 pkg-config를 먼저 include하고 쓰면 된다.

아직 네가 잘 못해서 Mac에서는 find_package가 먹지 않는다. 

3. 테스트 소스

#include <iostream> #include <string> #include <thread> #include <cstdio> #include <boost/interprocess/ipc/message_queue.hpp> typedef struct { char name[128]; int age; } testMessage_t; using namespace boost::interprocess; int main(int argc, char* argv[]) { int i = 0; char ch; testMessage_t smessage = {"heesoon.kim", 41}; testMessage_t rmessage = {0, }; std::string msgQName = "test"; try { //Erase previous message queue message_queue::remove(msgQName.c_str()); // task sending message to below task std::thread tr_send = std::thread([&]() { //Create a message_queue. message_queue mq //(open_or_create //create or open (create_only //create only ,msgQName.c_str() //name ,1 //max message number ,sizeof(smessage) //max message size ); while(i++ < 10) { mq.send(&smessage, sizeof(smessage), 0); } }); // task receiving message from above task std::thread tr_receive = std::thread([&]() { message_queue mq (open_only //only create ,msgQName.c_str() //name ); unsigned int priority; message_queue::size_type recvd_size; while(1) { mq.receive(&rmessage, sizeof(rmessage), recvd_size, priority); std::cout << "name : " << rmessage.name << ", "; std::cout << "age : " << rmessage.age << std::endl; } }); tr_send.detach(); tr_receive.detach(); } catch(interprocess_exception &ex){ std::cout << ex.what() << std::endl; return 1; } while(1) { std::cout << "In main thread" << std::endl; std::cin.get(ch); if(ch == 'x' || ch == 'X') break; } message_queue::remove(msgQName.c_str()); return 0; }