thread_wrapper_impl.hpp

Go to the documentation of this file.

/******************************************************************************
** Copyright © 2004 by J.M.McGuiness, coder@hussar.me.uk
**
** This library is free software; you can redistribute it and/or
** modify it under the terms of the GNU Lesser General Public
** License as published by the Free Software Foundation; either
** version 2.1 of the License, or (at your option) any later version.
**
** This library is distributed in the hope that it will be useful,
** but WITHOUT ANY WARRANTY; without even the implied warranty of
** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
** Lesser General Public License for more details.
**
** You should have received a copy of the GNU Lesser General Public
** License along with this library; if not, write to the Free Software
** Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
 
namespace jmmcg { namespace LIBJMMCG_VER_NAMESPACE { namespace ppd {
 
// Implementation details..... Don't look below here!!! ;)
 
// "wrapper" implementation...
/* Can't delete a sequential-traits thread.
   template<generic_traits::api_type API, class TWC> inline void
   wrapper<API, sequential_mode, TWC>::wait_thread_exit() {
   }
*/
   template<generic_traits::api_type API, class Mdl, class TWC> inline
   wrapper<API, Mdl, TWC>::wrapper(const typename thread_traits::api_params_type::suspend_period_ms ew) noexcept(false)
   : base_t(ew), exit_requested(false) {
   }
 
   template<generic_traits::api_type API, class Mdl, class TWC> inline
   wrapper<API, Mdl, TWC>::wrapper(thread_context_t &&thread_context, const typename thread_traits::api_params_type::suspend_period_ms ew) noexcept(false)
   : base_t(ew), exit_requested(false), thread_context_(std::move(thread_context)) {
   }
 
   template<generic_traits::api_type API, class Mdl, class TWC> inline
   wrapper<API, Mdl, TWC>::wrapper(const wrapper &tb) noexcept(true)
   : base_t(tb), exit_requested(false), thread_context_(tb.thread_context_) {
   }
 
   template<generic_traits::api_type API, class Mdl, class TWC> inline bool
   wrapper<API, Mdl, TWC>::pre_exit() noexcept(false) {
      return exit_requested;
   }
 
   template<generic_traits::api_type API, class Mdl, class TWC> inline typename wrapper<API, Mdl, TWC>::thread_traits::api_params_type::states
   wrapper<API, Mdl, TWC>::process() noexcept(false) {
      thread_context_t obj(std::move(thread_context_));
      while (!this->pre_exit() && !this->worker_fn(obj));
      return thread_traits::api_params_type::no_kernel_thread;
   }
 
   template<generic_traits::api_type API, class Mdl, class TWC> inline
   wrapper<API, Mdl, TWC>::~wrapper() noexcept(false) {
      this->exit_requested=true;
      base_t::wait_thread_exit();
      // See how I've tried to clean up everything before we might throw here?
      // Yeah - well - apart from all of the base class stuff, etc, etc. So it's really rather bad...
      this->exception_thrown_in_thread.throw_if_set();
   }
 
   template<generic_traits::api_type API, class Mdl> inline
   thread<API, Mdl>::thread(const typename thread_traits::api_params_type::suspend_period_ms ew) noexcept(false)
   : base_t(ew) {
   }
 
   template<generic_traits::api_type API, class Mdl>
   template<class ProcFn> inline
   thread<API, Mdl>::thread(ProcFn &&proc_fn, const typename thread_traits::api_params_type::suspend_period_ms ew) noexcept(false)
   : base_t(std::forward<ProcFn>(proc_fn), ew) {
      this->create_running();
   }
 
   template<generic_traits::api_type API, class Mdl> inline
   thread<API, Mdl>::~thread() noexcept(false) {
      this->exit_requested=true;
      base_t::wait_thread_exit();
   }
 
   template<generic_traits::api_type API, class Mdl> inline bool
   thread<API, Mdl>::worker_fn(thread_context_t &context) noexcept(false) {
      context();
      return true;
   }
 
} } }