#include #include #include #include "doc_anonymous_mutex_shared_data.hpp" #include #include using namespace boost::interprocess; int main () { try{ //Open the shared memory object. shared_memory_object shm (open_only //only create ,"shared_memory" //name ,read_write //read-write mode ); //Map the whole shared memory in this process mapped_region region (shm //What to map ,read_write //Map it as read-write ); //Get the address of the mapped region void * addr = region.get_address(); //Construct the shared structure in memory shared_memory_log * data = static_cast(addr); //Write some logs for(int i = 0; i < 100; ++i){ //Lock the mutex scoped_lock lock(data->mutex); std::sprintf(data->items[(data->current_line++) % shared_memory_log::NumItems] ,"%s_%d", "process_a", i); if(i == (shared_memory_log::NumItems-1)) data->end_b = true; //Mutex is released here } //Wait until the other process ends while(1){ scoped_lock lock(data->mutex); if(data->end_a) break; } } catch(interprocess_exception &ex){ std::cout << ex.what() << std::endl; return 1; } return 0; }