[Boost-commit] svn:boost r50584 - sandbox/interthreads/libs/interthreads/src

Subject: [Boost-commit] svn:boost r50584 - sandbox/interthreads/libs/interthreads/src
From: vicente.botet_at_[hidden]
Date: 2009-01-14 12:35:15

Author: viboes
Date: 2009-01-14 12:35:14 EST (Wed, 14 Jan 2009)
New Revision: 50584
URL: http://svn.boost.org/trac/boost/changeset/50584

Log:
interthreads version 0.2
Adding threader/joiner
Adding Asynchronous Executors fmk
Text files modified: 
   sandbox/interthreads/libs/interthreads/src/thread_decorator.cpp  |    10 ++--------                              
   sandbox/interthreads/libs/interthreads/src/thread_keep_alive.cpp |    10 +---------                              
   2 files changed, 3 insertions(+), 17 deletions(-)

Modified: sandbox/interthreads/libs/interthreads/src/thread_decorator.cpp
==============================================================================
--- sandbox/interthreads/libs/interthreads/src/thread_decorator.cpp	(original)
+++ sandbox/interthreads/libs/interthreads/src/thread_decorator.cpp	2009-01-14 12:35:14 EST (Wed, 14 Jan 2009)
@@ -1,7 +1,7 @@
 //////////////////////////////////////////////////////////////////////////////
 //
 // (C) Copyright Roland Schwarz 2006. 
-// (C) Copyright Vicente J. Botet Escriba 2008. 
+// (C) Copyright Vicente J. Botet Escriba 2008-20009. 
 // 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)
@@ -10,12 +10,11 @@
 //
 //////////////////////////////////////////////////////////////////////////////
 
-#include <boost/interthreads/thread_decorator.hpp>
+#include <boost/interthreads/thread_decoration.hpp>
 #include <boost/thread/thread.hpp>
 
 namespace boost {
 namespace interthreads {
-//boost::interthreads::
     thread_decoration* boost::interthreads::thread_decoration::last_ = 0;
 
     void thread_decoration::decorate() {
@@ -28,11 +27,6 @@
                     p = p->prev_;
             }
     }
-
-    void thread_decorator::operator()() const {
-        decorate();
-        (*func_)();
-    }
   
 }
 }

Modified: sandbox/interthreads/libs/interthreads/src/thread_keep_alive.cpp
==============================================================================
--- sandbox/interthreads/libs/interthreads/src/thread_keep_alive.cpp	(original)
+++ sandbox/interthreads/libs/interthreads/src/thread_keep_alive.cpp	2009-01-14 12:35:14 EST (Wed, 14 Jan 2009)
@@ -1,6 +1,6 @@
 //////////////////////////////////////////////////////////////////////////////
 //
-// (C) Copyright Vicente J. Botet Escriba 2008. Distributed under the Boost
+// (C) Copyright Vicente J. Botet Escriba 2008-20009. 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)
 //
@@ -122,7 +122,6 @@
 
                 boost::thread thread_;
                 static once_flag flag;
-//		static keep_alive_mgr* instance_;
 //		keep_alive_mgr(const keep_alive_mgr&);
                 
         };
@@ -170,7 +169,6 @@
     enable_keep_alive::enable_keep_alive(
             std::size_t periods, std::size_t checkins) 
     {
-    //	if (detail::thread_keep_alive_ctx::instance().get()==0) throw error;
         backup_=detail::thread_keep_alive_ctx::instance()->backup(&data_);
         detail::thread_keep_alive_ctx::instance()->enable_keep_alive(periods, checkins);
     }
@@ -180,7 +178,6 @@
     }
 
     disable_keep_alive::disable_keep_alive() {
-    //	if (detail::thread_keep_alive_ctx::instance().get()==0) throw error;
         backup_=detail::thread_keep_alive_ctx::instance()->backup(&data_);
         detail::thread_keep_alive_ctx::instance()->disable_keep_alive();
     }
@@ -190,19 +187,14 @@
     }
 
 void keep_alive_point() {
-//	if (detail::thread_keep_alive_ctx::instance().get()==0) throw error;
         detail::thread_keep_alive_ctx::instance()->check_point();
 }
 
 bool keep_alive_enabled() {
-//	if (detail::thread_keep_alive_ctx::instance().get()==0) throw error;
         return detail::thread_keep_alive_ctx::instance()->enabled();
 }
 
-//void set_on_dead_thread(on_dead_thread_type fct, thread* th) { 
 void set_on_dead_thread(void (*fct)(thread::id, thread*), thread* th) {
-
-//	if (detail::thread_keep_alive_ctx::instance().get()==0) throw error;
         detail::thread_keep_alive_ctx::instance()->set_on_dead_thread(fct, th);
 }