synchronized_value.cpp 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147
  1. // (C) Copyright 2010 Just Software Solutions Ltd http://www.justsoftwaresolutions.co.uk
  2. // (C) Copyright 2012 Vicente Botet
  3. //
  4. // Distributed under the Boost Software License, Version 1.0. (See accompanying
  5. // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
  6. #define BOOST_THREAD_VERSION 4
  7. #include <iostream>
  8. #include <string>
  9. #include <boost/thread/synchronized_value.hpp>
  10. void addTrailingSlashIfMissing(boost::synchronized_value<std::string> & path)
  11. {
  12. boost::strict_lock_ptr<std::string> u=path.synchronize();
  13. if(u->empty() || (*u->rbegin()!='/'))
  14. {
  15. *u+='/';
  16. }
  17. }
  18. void f(const boost::synchronized_value<int> &v) {
  19. std::cout<<"v="<<*v<<std::endl;
  20. }
  21. void g(const boost::const_strict_lock_ptr<int> &v) {
  22. std::cout<<"v="<<*v<<std::endl;
  23. }
  24. bool checkIfMissingTrailingSlash(boost::synchronized_value<std::string> & path)
  25. {
  26. boost::strict_lock_ptr<std::string> u=path.synchronize();
  27. return (u->empty() || (*u->rbegin()!='/'));
  28. }
  29. int main()
  30. {
  31. {
  32. boost::synchronized_value<int> v1;
  33. *v1=42;
  34. std::cout<<"v1="<<*v1<<std::endl;
  35. f(v1);
  36. int i=*v1;
  37. std::cout<<"i="<<i<<std::endl;
  38. {
  39. boost::strict_lock_ptr<int> u=v1.synchronize();
  40. *u+=43;
  41. std::cout<<"v1="<<*u<<std::endl;
  42. g(u);
  43. }
  44. boost::synchronized_value<int> v2(2);
  45. std::cout<<"v2="<<*v2<<std::endl;
  46. v2 = 3;
  47. std::cout<<"v2="<<*v2<<std::endl;
  48. boost::synchronized_value<int> v3(v2);
  49. std::cout<<"v3="<<*v3<<std::endl;
  50. v3 = v1;
  51. std::cout<<"v3="<<*v3<<std::endl;
  52. std::cout<<"v2="<<*v3<<std::endl;
  53. std::cout<<"v3="<<*v3<<std::endl;
  54. swap(v3,v2);
  55. v1.swap(v2);
  56. std::cout<<"v3="<<*v3<<std::endl;
  57. }
  58. {
  59. boost::synchronized_value<std::string> s;
  60. addTrailingSlashIfMissing(s);
  61. std::cout<<"s="<<std::string(*s)<<std::endl;
  62. }
  63. {
  64. boost::synchronized_value<std::string> s;
  65. s->append("foo/");
  66. s.synchronize()->append("foo");
  67. addTrailingSlashIfMissing(s);
  68. std::cout<<"s="<<std::string(*s)<<std::endl;
  69. }
  70. {
  71. boost::synchronized_value<std::string> s;
  72. s = std::string("foo/");
  73. std::cout<<"ss="<< s << std::endl;
  74. }
  75. {
  76. boost::synchronized_value<std::string> s;
  77. s = "foo/";
  78. std::cout<<"ss="<< s << std::endl;
  79. }
  80. {
  81. boost::synchronized_value<std::string> s1("a");
  82. boost::synchronized_value<std::string> s2;
  83. s2=s1;
  84. std::cout<<"s1="<< s1 << std::endl;
  85. std::cout<<"s2="<< s2 << std::endl;
  86. }
  87. {
  88. boost::synchronized_value<std::string> s1("a");
  89. boost::synchronized_value<std::string> s2("b");
  90. std::cout<<"s1="<< s1 << std::endl;
  91. std::cout<<"s2="<< s2 << std::endl;
  92. swap(s1,s2);
  93. std::cout<<"s1="<< s1 << std::endl;
  94. std::cout<<"s2="<< s2 << std::endl;
  95. }
  96. #if ! defined(BOOST_NO_CXX11_EXPLICIT_CONVERSION_OPERATORS)
  97. {
  98. boost::synchronized_value<std::string> sts("a");
  99. std::string s(sts);
  100. std::cout<<"ssts="<< s << std::endl;
  101. }
  102. #endif
  103. {
  104. boost::synchronized_value<int> s1(1);
  105. boost::synchronized_value<int> s2(1);
  106. BOOST_ASSERT(s1==s2);
  107. BOOST_ASSERT(s1<=s2);
  108. BOOST_ASSERT(s1>=s2);
  109. BOOST_ASSERT(s1==1);
  110. BOOST_ASSERT(s1<=1);
  111. BOOST_ASSERT(s1>=1);
  112. }
  113. {
  114. boost::synchronized_value<int> s1(1);
  115. boost::synchronized_value<int> s2(2);
  116. BOOST_ASSERT(s1!=s2);
  117. BOOST_ASSERT(s1!=2);
  118. BOOST_ASSERT(2!=s1);
  119. }
  120. {
  121. boost::synchronized_value<int> s1(1);
  122. boost::synchronized_value<int> s2(2);
  123. BOOST_ASSERT(s1<s2);
  124. BOOST_ASSERT(s1<=s2);
  125. BOOST_ASSERT(s2>s1);
  126. BOOST_ASSERT(s2>=s1);
  127. BOOST_ASSERT(s1<2);
  128. BOOST_ASSERT(s1<=2);
  129. BOOST_ASSERT(s2>1);
  130. BOOST_ASSERT(s2>=1);
  131. }
  132. return 0;
  133. }