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);
}