message queue - with boost lib

Program Lang./C++

message queue - with boost lib

chipmaker 2016. 7. 11. 08:39

네가 만든 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;
}