12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697 |
- //////////////////////////////////////////////////////////////////////////////
- //
- // (C) Copyright Ion Gaztanaga 2006-2012. Distributed under the Boost
- // Software License, Version 1.0. (See accompanying file
- // LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
- //
- // See http://www.boost.org/libs/interprocess for documentation.
- //
- //////////////////////////////////////////////////////////////////////////////
- #include <boost/interprocess/detail/config_begin.hpp>
- //[doc_named_mutex
- #include <boost/interprocess/sync/scoped_lock.hpp>
- #include <boost/interprocess/sync/named_mutex.hpp>
- #include <fstream>
- #include <iostream>
- #include <cstdio>
- //<-
- #include "../test/get_process_id_name.hpp"
- //->
- int main ()
- {
- using namespace boost::interprocess;
- try{
- struct file_remove
- {
- //<-
- #if 1
- file_remove() { std::remove(test::get_process_id_name()); }
- ~file_remove(){ std::remove(test::get_process_id_name()); }
- #else
- //->
- file_remove() { std::remove("file_name"); }
- ~file_remove(){ std::remove("file_name"); }
- //<-
- #endif
- //->
- } file_remover;
- struct mutex_remove
- {
- //<-
- #if 1
- mutex_remove() { named_mutex::remove(test::get_process_id_name()); }
- ~mutex_remove(){ named_mutex::remove(test::get_process_id_name()); }
- #else
- //->
- mutex_remove() { named_mutex::remove("fstream_named_mutex"); }
- ~mutex_remove(){ named_mutex::remove("fstream_named_mutex"); }
- //<-
- #endif
- //->
- } remover;
- //<-
- (void)remover;
- //->
- //Open or create the named mutex
- //<-
- #if 1
- named_mutex mutex(open_or_create, test::get_process_id_name());
- #else
- //->
- named_mutex mutex(open_or_create, "fstream_named_mutex");
- //<-
- #endif
- //->
- //<-
- #if 1
- std::ofstream file(test::get_process_id_name());
- #else
- //->
- std::ofstream file("file_name");
- //<-
- #endif
- //->
- for(int i = 0; i < 10; ++i){
- //Do some operations...
- //Write to file atomically
- scoped_lock<named_mutex> lock(mutex);
- file << "Process name, ";
- file << "This is iteration #" << i;
- file << std::endl;
- }
- }
- catch(interprocess_exception &ex){
- std::cout << ex.what() << std::endl;
- return 1;
- }
- return 0;
- }
- //]
- #include <boost/interprocess/detail/config_end.hpp>
|