Chris@16: //  (C) Copyright 2008-10 Anthony Williams
Chris@16: //  (C) Copyright 2011-2013 Vicente J. Botet Escriba
Chris@16: //
Chris@16: //  Distributed under the Boost Software License, Version 1.0. (See
Chris@16: //  accompanying file LICENSE_1_0.txt or copy at
Chris@16: //  http://www.boost.org/LICENSE_1_0.txt)
Chris@16: 
Chris@16: #ifndef BOOST_THREAD_FUTURE_HPP
Chris@16: #define BOOST_THREAD_FUTURE_HPP
Chris@16: 
Chris@16: #include <boost/thread/detail/config.hpp>
Chris@16: 
Chris@16: // boost::thread::future requires exception handling
Chris@16: // due to boost::exception::exception_ptr dependency
Chris@16: 
Chris@16: #ifndef BOOST_NO_EXCEPTIONS
Chris@16: 
Chris@16: //#include <boost/thread/detail/log.hpp>
Chris@16: #include <boost/detail/scoped_enum_emulation.hpp>
Chris@16: #include <stdexcept>
Chris@16: #include <boost/thread/detail/move.hpp>
Chris@16: #include <boost/thread/detail/async_func.hpp>
Chris@16: #include <boost/thread/thread_time.hpp>
Chris@16: #include <boost/thread/mutex.hpp>
Chris@16: #include <boost/thread/condition_variable.hpp>
Chris@16: #include <boost/thread/lock_algorithms.hpp>
Chris@16: #include <boost/thread/lock_types.hpp>
Chris@16: #include <boost/exception_ptr.hpp>
Chris@16: #include <boost/shared_ptr.hpp>
Chris@16: #include <boost/scoped_ptr.hpp>
Chris@16: #include <boost/type_traits/is_fundamental.hpp>
Chris@16: #include <boost/thread/detail/is_convertible.hpp>
Chris@16: #include <boost/type_traits/remove_reference.hpp>
Chris@16: #include <boost/type_traits/remove_cv.hpp>
Chris@16: #include <boost/type_traits/is_void.hpp>
Chris@16: #include <boost/mpl/if.hpp>
Chris@16: #include <boost/config.hpp>
Chris@16: #include <boost/throw_exception.hpp>
Chris@16: #include <algorithm>
Chris@16: #include <boost/function.hpp>
Chris@16: #include <boost/bind.hpp>
Chris@16: #include <boost/ref.hpp>
Chris@16: #include <boost/scoped_array.hpp>
Chris@16: #include <boost/enable_shared_from_this.hpp>
Chris@16: #include <boost/utility/enable_if.hpp>
Chris@16: #include <list>
Chris@16: #include <boost/next_prior.hpp>
Chris@16: #include <vector>
Chris@16: 
Chris@16: #include <boost/thread/future_error_code.hpp>
Chris@16: #ifdef BOOST_THREAD_USES_CHRONO
Chris@16: #include <boost/chrono/system_clocks.hpp>
Chris@16: #endif
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_CTOR_ALLOCATORS
Chris@16: #include <boost/thread/detail/memory.hpp>
Chris@16: #endif
Chris@16: 
Chris@16: #include <boost/utility/result_of.hpp>
Chris@16: #include <boost/thread/thread_only.hpp>
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE
Chris@16: #define BOOST_THREAD_FUTURE future
Chris@16: #else
Chris@16: #define BOOST_THREAD_FUTURE unique_future
Chris@16: #endif
Chris@16: 
Chris@16: namespace boost
Chris@16: {
Chris@16: 
Chris@16:   //enum class launch
Chris@16:   BOOST_SCOPED_ENUM_DECLARE_BEGIN(launch)
Chris@16:   {
Chris@16:       none = 0,
Chris@16:       async = 1,
Chris@16:       deferred = 2,
Chris@16:       any = async | deferred
Chris@16:   }
Chris@16:   BOOST_SCOPED_ENUM_DECLARE_END(launch)
Chris@16: 
Chris@16:   //enum class future_status
Chris@16:   BOOST_SCOPED_ENUM_DECLARE_BEGIN(future_status)
Chris@16:   {
Chris@16:       ready,
Chris@16:       timeout,
Chris@16:       deferred
Chris@16:   }
Chris@16:   BOOST_SCOPED_ENUM_DECLARE_END(future_status)
Chris@16: 
Chris@16:   class BOOST_SYMBOL_VISIBLE future_error
Chris@16:       : public std::logic_error
Chris@16:   {
Chris@16:       system::error_code ec_;
Chris@16:   public:
Chris@16:       future_error(system::error_code ec)
Chris@16:       : logic_error(ec.message()),
Chris@16:         ec_(ec)
Chris@16:       {
Chris@16:       }
Chris@16: 
Chris@16:       const system::error_code& code() const BOOST_NOEXCEPT
Chris@16:       {
Chris@16:         return ec_;
Chris@16:       }
Chris@16:   };
Chris@16: 
Chris@16:     class BOOST_SYMBOL_VISIBLE future_uninitialized:
Chris@16:         public future_error
Chris@16:     {
Chris@16:     public:
Chris@16:         future_uninitialized() :
Chris@16:           future_error(system::make_error_code(future_errc::no_state))
Chris@16:         {}
Chris@16:     };
Chris@16:     class BOOST_SYMBOL_VISIBLE broken_promise:
Chris@16:         public future_error
Chris@16:     {
Chris@16:     public:
Chris@16:         broken_promise():
Chris@16:           future_error(system::make_error_code(future_errc::broken_promise))
Chris@16:         {}
Chris@16:     };
Chris@16:     class BOOST_SYMBOL_VISIBLE future_already_retrieved:
Chris@16:         public future_error
Chris@16:     {
Chris@16:     public:
Chris@16:         future_already_retrieved():
Chris@16:           future_error(system::make_error_code(future_errc::future_already_retrieved))
Chris@16:         {}
Chris@16:     };
Chris@16:     class BOOST_SYMBOL_VISIBLE promise_already_satisfied:
Chris@16:         public future_error
Chris@16:     {
Chris@16:     public:
Chris@16:         promise_already_satisfied():
Chris@16:           future_error(system::make_error_code(future_errc::promise_already_satisfied))
Chris@16:         {}
Chris@16:     };
Chris@16: 
Chris@16:     class BOOST_SYMBOL_VISIBLE task_already_started:
Chris@16:         public future_error
Chris@16:     {
Chris@16:     public:
Chris@16:         task_already_started():
Chris@16:         future_error(system::make_error_code(future_errc::promise_already_satisfied))
Chris@16:         {}
Chris@16:     };
Chris@16: 
Chris@16:     class BOOST_SYMBOL_VISIBLE task_moved:
Chris@16:         public future_error
Chris@16:     {
Chris@16:     public:
Chris@16:         task_moved():
Chris@16:           future_error(system::make_error_code(future_errc::no_state))
Chris@16:         {}
Chris@16:     };
Chris@16: 
Chris@16:     class promise_moved:
Chris@16:         public future_error
Chris@16:     {
Chris@16:     public:
Chris@16:           promise_moved():
Chris@16:           future_error(system::make_error_code(future_errc::no_state))
Chris@16:         {}
Chris@16:     };
Chris@16: 
Chris@16:     namespace future_state
Chris@16:     {
Chris@16:         enum state { uninitialized, waiting, ready, moved, deferred };
Chris@16:     }
Chris@16: 
Chris@16:     namespace detail
Chris@16:     {
Chris@16:         struct relocker
Chris@16:         {
Chris@16:             boost::unique_lock<boost::mutex>& lock_;
Chris@16:             bool  unlocked_;
Chris@16: 
Chris@16:             relocker(boost::unique_lock<boost::mutex>& lk):
Chris@16:                 lock_(lk)
Chris@16:             {
Chris@16:                 lock_.unlock();
Chris@16:                 unlocked_=true;
Chris@16:             }
Chris@16:             ~relocker()
Chris@16:             {
Chris@16:               if (unlocked_) {
Chris@16:                 lock_.lock();
Chris@16:               }
Chris@16:             }
Chris@16:             void lock() {
Chris@16:               if (unlocked_) {
Chris@16:                 lock_.lock();
Chris@16:                 unlocked_=false;
Chris@16:               }
Chris@16:             }
Chris@16:         private:
Chris@16:             relocker& operator=(relocker const&);
Chris@16:         };
Chris@16: 
Chris@16:         struct shared_state_base : enable_shared_from_this<shared_state_base>
Chris@16:         {
Chris@16:             typedef std::list<boost::condition_variable_any*> waiter_list;
Chris@16:             // This type should be only included conditionally if interruptions are allowed, but is included to maintain the same layout.
Chris@16:             typedef shared_ptr<shared_state_base> continuation_ptr_type;
Chris@16: 
Chris@16:             boost::exception_ptr exception;
Chris@16:             bool done;
Chris@16:             bool is_deferred_;
Chris@16:             launch policy_;
Chris@16:             bool is_constructed;
Chris@16:             mutable boost::mutex mutex;
Chris@16:             boost::condition_variable waiters;
Chris@16:             waiter_list external_waiters;
Chris@16:             boost::function<void()> callback;
Chris@16:             // This declaration should be only included conditionally if interruptions are allowed, but is included to maintain the same layout.
Chris@16:             bool thread_was_interrupted;
Chris@16:             // This declaration should be only included conditionally, but is included to maintain the same layout.
Chris@16:             continuation_ptr_type continuation_ptr;
Chris@16: 
Chris@16:             // This declaration should be only included conditionally, but is included to maintain the same layout.
Chris@16:             virtual void launch_continuation(boost::unique_lock<boost::mutex>&)
Chris@16:             {
Chris@16:             }
Chris@16: 
Chris@16:             shared_state_base():
Chris@16:                 done(false),
Chris@16:                 is_deferred_(false),
Chris@16:                 policy_(launch::none),
Chris@16:                 is_constructed(false),
Chris@16:                 thread_was_interrupted(false),
Chris@16:                 continuation_ptr()
Chris@16:             {}
Chris@16:             virtual ~shared_state_base()
Chris@16:             {}
Chris@16: 
Chris@16:             void set_deferred()
Chris@16:             {
Chris@16:               is_deferred_ = true;
Chris@16:               policy_ = launch::deferred;
Chris@16:             }
Chris@16:             void set_async()
Chris@16:             {
Chris@16:               is_deferred_ = false;
Chris@16:               policy_ = launch::async;
Chris@16:             }
Chris@16: 
Chris@16:             waiter_list::iterator register_external_waiter(boost::condition_variable_any& cv)
Chris@16:             {
Chris@16:                 boost::unique_lock<boost::mutex> lock(mutex);
Chris@16:                 do_callback(lock);
Chris@16:                 return external_waiters.insert(external_waiters.end(),&cv);
Chris@16:             }
Chris@16: 
Chris@16:             void remove_external_waiter(waiter_list::iterator it)
Chris@16:             {
Chris@16:                 boost::lock_guard<boost::mutex> lock(mutex);
Chris@16:                 external_waiters.erase(it);
Chris@16:             }
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION
Chris@16:             void do_continuation(boost::unique_lock<boost::mutex>& lock)
Chris@16:             {
Chris@16:                 if (continuation_ptr) {
Chris@16:                   continuation_ptr->launch_continuation(lock);
Chris@16:                   if (! lock.owns_lock())
Chris@16:                     lock.lock();
Chris@16:                   continuation_ptr.reset();
Chris@16:                 }
Chris@16:             }
Chris@16: #else
Chris@16:             void do_continuation(boost::unique_lock<boost::mutex>&)
Chris@16:             {
Chris@16:             }
Chris@16: #endif
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION
Chris@16:             void set_continuation_ptr(continuation_ptr_type continuation, boost::unique_lock<boost::mutex>& lock)
Chris@16:             {
Chris@16:               continuation_ptr= continuation;
Chris@16:               if (done) {
Chris@16:                 do_continuation(lock);
Chris@16:               }
Chris@16:             }
Chris@16: #endif
Chris@16:             void mark_finished_internal(boost::unique_lock<boost::mutex>& lock)
Chris@16:             {
Chris@16:                 done=true;
Chris@16:                 waiters.notify_all();
Chris@16:                 for(waiter_list::const_iterator it=external_waiters.begin(),
Chris@16:                         end=external_waiters.end();it!=end;++it)
Chris@16:                 {
Chris@16:                     (*it)->notify_all();
Chris@16:                 }
Chris@16:                 do_continuation(lock);
Chris@16:             }
Chris@16:             void make_ready()
Chris@16:             {
Chris@16:               boost::unique_lock<boost::mutex> lock(mutex);
Chris@16:               mark_finished_internal(lock);
Chris@16:             }
Chris@16: 
Chris@16:             void do_callback(boost::unique_lock<boost::mutex>& lock)
Chris@16:             {
Chris@16:                 if(callback && !done)
Chris@16:                 {
Chris@16:                     boost::function<void()> local_callback=callback;
Chris@16:                     relocker relock(lock);
Chris@16:                     local_callback();
Chris@16:                 }
Chris@16:             }
Chris@16: 
Chris@16:             void wait_internal(boost::unique_lock<boost::mutex> &lk, bool rethrow=true)
Chris@16:             {
Chris@16:               do_callback(lk);
Chris@16:               //if (!done) // fixme why this doesn't work?
Chris@16:               {
Chris@16:                 if (is_deferred_)
Chris@16:                 {
Chris@16:                   is_deferred_=false;
Chris@16:                   execute(lk);
Chris@16:                   //lk.unlock();
Chris@16:                 }
Chris@16:                 else
Chris@16:                 {
Chris@16:                   while(!done)
Chris@16:                   {
Chris@16:                       waiters.wait(lk);
Chris@16:                   }
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                   if(rethrow && thread_was_interrupted)
Chris@16:                   {
Chris@16:                       throw boost::thread_interrupted();
Chris@16:                   }
Chris@16: #endif
Chris@16:                   if(rethrow && exception)
Chris@16:                   {
Chris@16:                       boost::rethrow_exception(exception);
Chris@16:                   }
Chris@16:                 }
Chris@16:               }
Chris@16:             }
Chris@16: 
Chris@16:             virtual void wait(bool rethrow=true)
Chris@16:             {
Chris@16:                 boost::unique_lock<boost::mutex> lock(mutex);
Chris@16:                 wait_internal(lock, rethrow);
Chris@16:             }
Chris@16: 
Chris@16: #if defined BOOST_THREAD_USES_DATETIME
Chris@16:             bool timed_wait_until(boost::system_time const& target_time)
Chris@16:             {
Chris@16:                 boost::unique_lock<boost::mutex> lock(mutex);
Chris@16:                 if (is_deferred_)
Chris@16:                     return false;
Chris@16: 
Chris@16:                 do_callback(lock);
Chris@16:                 while(!done)
Chris@16:                 {
Chris@16:                     bool const success=waiters.timed_wait(lock,target_time);
Chris@16:                     if(!success && !done)
Chris@16:                     {
Chris@16:                         return false;
Chris@16:                     }
Chris@16:                 }
Chris@16:                 return true;
Chris@16:             }
Chris@16: #endif
Chris@16: #ifdef BOOST_THREAD_USES_CHRONO
Chris@16: 
Chris@16:             template <class Clock, class Duration>
Chris@16:             future_status
Chris@16:             wait_until(const chrono::time_point<Clock, Duration>& abs_time)
Chris@16:             {
Chris@16:               boost::unique_lock<boost::mutex> lock(mutex);
Chris@16:               if (is_deferred_)
Chris@16:                   return future_status::deferred;
Chris@16:               do_callback(lock);
Chris@16:               while(!done)
Chris@16:               {
Chris@16:                   cv_status const st=waiters.wait_until(lock,abs_time);
Chris@16:                   if(st==cv_status::timeout && !done)
Chris@16:                   {
Chris@16:                     return future_status::timeout;
Chris@16:                   }
Chris@16:               }
Chris@16:               return future_status::ready;
Chris@16:             }
Chris@16: #endif
Chris@16:             void mark_exceptional_finish_internal(boost::exception_ptr const& e, boost::unique_lock<boost::mutex>& lock)
Chris@16:             {
Chris@16:                 exception=e;
Chris@16:                 mark_finished_internal(lock);
Chris@16:             }
Chris@16: 
Chris@16:             void mark_exceptional_finish()
Chris@16:             {
Chris@16:                 boost::unique_lock<boost::mutex> lock(mutex);
Chris@16:                 mark_exceptional_finish_internal(boost::current_exception(), lock);
Chris@16:             }
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:             void mark_interrupted_finish()
Chris@16:             {
Chris@16:                 boost::unique_lock<boost::mutex> lock(mutex);
Chris@16:                 thread_was_interrupted=true;
Chris@16:                 mark_finished_internal(lock);
Chris@16:             }
Chris@16: 
Chris@16:             void set_interrupted_at_thread_exit()
Chris@16:             {
Chris@16:               unique_lock<boost::mutex> lk(mutex);
Chris@16:               thread_was_interrupted=true;
Chris@16:               if (has_value(lk))
Chris@16:               {
Chris@16:                   throw_exception(promise_already_satisfied());
Chris@16:               }
Chris@16:               detail::make_ready_at_thread_exit(shared_from_this());
Chris@16:             }
Chris@16: #endif
Chris@16: 
Chris@16:             void set_exception_at_thread_exit(exception_ptr e)
Chris@16:             {
Chris@16:               unique_lock<boost::mutex> lk(mutex);
Chris@16:               if (has_value(lk))
Chris@16:               {
Chris@16:                   throw_exception(promise_already_satisfied());
Chris@16:               }
Chris@16:               exception=e;
Chris@16:               this->is_constructed = true;
Chris@16:               detail::make_ready_at_thread_exit(shared_from_this());
Chris@16: 
Chris@16:             }
Chris@16: 
Chris@16:             bool has_value() const
Chris@16:             {
Chris@16:                 boost::lock_guard<boost::mutex> lock(mutex);
Chris@16:                 return done && !(exception
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                     || thread_was_interrupted
Chris@16: #endif
Chris@16:                 );
Chris@16:             }
Chris@16: 
Chris@16:             bool has_value(unique_lock<boost::mutex>& )  const
Chris@16:             {
Chris@16:                 return done && !(exception
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                     || thread_was_interrupted
Chris@16: #endif
Chris@16:                 );
Chris@16:             }
Chris@16: 
Chris@16:             bool has_exception()  const
Chris@16:             {
Chris@16:                 boost::lock_guard<boost::mutex> lock(mutex);
Chris@16:                 return done && (exception
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                     || thread_was_interrupted
Chris@16: #endif
Chris@16:                     );
Chris@16:             }
Chris@16: 
Chris@16:             bool has_exception(unique_lock<boost::mutex>&) const
Chris@16:             {
Chris@16:                 return done && (exception
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                     || thread_was_interrupted
Chris@16: #endif
Chris@16:                     );
Chris@16:             }
Chris@16: 
Chris@16:             bool is_deferred(boost::lock_guard<boost::mutex>&)  const {
Chris@16:                 return is_deferred_;
Chris@16:             }
Chris@16: 
Chris@16:             launch launch_policy(boost::unique_lock<boost::mutex>&) const
Chris@16:             {
Chris@16:                 return policy_;
Chris@16:             }
Chris@16: 
Chris@16:             future_state::state get_state() const
Chris@16:             {
Chris@16:                 boost::lock_guard<boost::mutex> guard(mutex);
Chris@16:                 if(!done)
Chris@16:                 {
Chris@16:                     return future_state::waiting;
Chris@16:                 }
Chris@16:                 else
Chris@16:                 {
Chris@16:                     return future_state::ready;
Chris@16:                 }
Chris@16:             }
Chris@16: 
Chris@16:             exception_ptr get_exception_ptr()
Chris@16:             {
Chris@16:                 boost::unique_lock<boost::mutex> lock(mutex);
Chris@16:                 return get_exception_ptr(lock);
Chris@16:             }
Chris@16:             exception_ptr get_exception_ptr(boost::unique_lock<boost::mutex>& lock)
Chris@16:             {
Chris@16:                 wait_internal(lock, false);
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                 if(thread_was_interrupted)
Chris@16:                 {
Chris@16:                     return copy_exception(boost::thread_interrupted());
Chris@16:                 }
Chris@16: #endif
Chris@16:                 return exception;
Chris@16:             }
Chris@16: 
Chris@16:             template<typename F,typename U>
Chris@16:             void set_wait_callback(F f,U* u)
Chris@16:             {
Chris@16:                 boost::lock_guard<boost::mutex> lock(mutex);
Chris@16:                 callback=boost::bind(f,boost::ref(*u));
Chris@16:             }
Chris@16: 
Chris@16:             virtual void execute(boost::unique_lock<boost::mutex>&) {}
Chris@16: 
Chris@16:         private:
Chris@16:             shared_state_base(shared_state_base const&);
Chris@16:             shared_state_base& operator=(shared_state_base const&);
Chris@16:         };
Chris@16: 
Chris@16:         template<typename T>
Chris@16:         struct future_traits
Chris@16:         {
Chris@16:           typedef boost::scoped_ptr<T> storage_type;
Chris@16:           struct dummy;
Chris@16: #ifndef BOOST_NO_CXX11_RVALUE_REFERENCES
Chris@16:           typedef T const& source_reference_type;
Chris@16:           //typedef typename boost::mpl::if_<boost::is_fundamental<T>,dummy&,BOOST_THREAD_RV_REF(T)>::type rvalue_source_type;
Chris@16:           typedef BOOST_THREAD_RV_REF(T) rvalue_source_type;
Chris@16:           //typedef typename boost::mpl::if_<boost::is_fundamental<T>,T,BOOST_THREAD_RV_REF(T)>::type move_dest_type;
Chris@16:           typedef T move_dest_type;
Chris@16: #elif defined BOOST_THREAD_USES_MOVE
Chris@16:           typedef typename boost::mpl::if_c<boost::is_fundamental<T>::value,T,T&>::type source_reference_type;
Chris@16:           //typedef typename boost::mpl::if_c<boost::is_fundamental<T>::value,T,BOOST_THREAD_RV_REF(T)>::type rvalue_source_type;
Chris@16:           //typedef typename boost::mpl::if_c<boost::enable_move_utility_emulation<T>::value,BOOST_THREAD_RV_REF(T),T>::type move_dest_type;
Chris@16:           typedef BOOST_THREAD_RV_REF(T) rvalue_source_type;
Chris@16:           typedef T move_dest_type;
Chris@16: #else
Chris@16:           typedef T& source_reference_type;
Chris@16:           typedef typename boost::mpl::if_<boost::thread_detail::is_convertible<T&,BOOST_THREAD_RV_REF(T) >,BOOST_THREAD_RV_REF(T),T const&>::type rvalue_source_type;
Chris@16:           typedef typename boost::mpl::if_<boost::thread_detail::is_convertible<T&,BOOST_THREAD_RV_REF(T) >,BOOST_THREAD_RV_REF(T),T>::type move_dest_type;
Chris@16: #endif
Chris@16: 
Chris@16: 
Chris@16:             typedef const T& shared_future_get_result_type;
Chris@16: 
Chris@16:             static void init(storage_type& storage,source_reference_type t)
Chris@16:             {
Chris@16:                 storage.reset(new T(t));
Chris@16:             }
Chris@16: 
Chris@16:             static void init(storage_type& storage,rvalue_source_type t)
Chris@16:             {
Chris@16: #if ! defined  BOOST_NO_CXX11_RVALUE_REFERENCES
Chris@16:               storage.reset(new T(boost::forward<T>(t)));
Chris@16: #else
Chris@16:               storage.reset(new T(static_cast<rvalue_source_type>(t)));
Chris@16: #endif
Chris@16:             }
Chris@16: 
Chris@16:             static void cleanup(storage_type& storage)
Chris@16:             {
Chris@16:                 storage.reset();
Chris@16:             }
Chris@16:         };
Chris@16: 
Chris@16:         template<typename T>
Chris@16:         struct future_traits<T&>
Chris@16:         {
Chris@16:             typedef T* storage_type;
Chris@16:             typedef T& source_reference_type;
Chris@16:             //struct rvalue_source_type
Chris@16:             //{};
Chris@16:             typedef T& move_dest_type;
Chris@16:             typedef T& shared_future_get_result_type;
Chris@16: 
Chris@16:             static void init(storage_type& storage,T& t)
Chris@16:             {
Chris@16:                 storage=&t;
Chris@16:             }
Chris@16: 
Chris@16:             static void cleanup(storage_type& storage)
Chris@16:             {
Chris@16:                 storage=0;
Chris@16:             }
Chris@16:         };
Chris@16: 
Chris@16:         template<>
Chris@16:         struct future_traits<void>
Chris@16:         {
Chris@16:             typedef bool storage_type;
Chris@16:             typedef void move_dest_type;
Chris@16:             typedef void shared_future_get_result_type;
Chris@16: 
Chris@16:             static void init(storage_type& storage)
Chris@16:             {
Chris@16:                 storage=true;
Chris@16:             }
Chris@16: 
Chris@16:             static void cleanup(storage_type& storage)
Chris@16:             {
Chris@16:                 storage=false;
Chris@16:             }
Chris@16: 
Chris@16:         };
Chris@16: 
Chris@16:         // Used to create stand-alone futures
Chris@16:         template<typename T>
Chris@16:         struct shared_state:
Chris@16:             detail::shared_state_base
Chris@16:         {
Chris@16:             typedef typename future_traits<T>::storage_type storage_type;
Chris@16:             typedef typename future_traits<T>::source_reference_type source_reference_type;
Chris@16:             typedef typename future_traits<T>::rvalue_source_type rvalue_source_type;
Chris@16:             typedef typename future_traits<T>::move_dest_type move_dest_type;
Chris@16:             typedef typename future_traits<T>::shared_future_get_result_type shared_future_get_result_type;
Chris@16: 
Chris@16:             storage_type result;
Chris@16: 
Chris@16:             shared_state():
Chris@16:                 result(0)
Chris@16:             {}
Chris@16: 
Chris@16:             ~shared_state()
Chris@16:             {}
Chris@16: 
Chris@16:             void mark_finished_with_result_internal(source_reference_type result_, boost::unique_lock<boost::mutex>& lock)
Chris@16:             {
Chris@16:                 future_traits<T>::init(result,result_);
Chris@16:                 this->mark_finished_internal(lock);
Chris@16:             }
Chris@16: 
Chris@16:             void mark_finished_with_result_internal(rvalue_source_type result_, boost::unique_lock<boost::mutex>& lock)
Chris@16:             {
Chris@16: #if ! defined  BOOST_NO_CXX11_RVALUE_REFERENCES
Chris@16:                 future_traits<T>::init(result,boost::forward<T>(result_));
Chris@16: #else
Chris@16:                 future_traits<T>::init(result,static_cast<rvalue_source_type>(result_));
Chris@16: #endif
Chris@16:                 this->mark_finished_internal(lock);
Chris@16:             }
Chris@16: 
Chris@16:             void mark_finished_with_result(source_reference_type result_)
Chris@16:             {
Chris@16:                 boost::unique_lock<boost::mutex> lock(mutex);
Chris@16:                 this->mark_finished_with_result_internal(result_, lock);
Chris@16:             }
Chris@16: 
Chris@16:             void mark_finished_with_result(rvalue_source_type result_)
Chris@16:             {
Chris@16:                 boost::unique_lock<boost::mutex> lock(mutex);
Chris@16: 
Chris@16: #if ! defined  BOOST_NO_CXX11_RVALUE_REFERENCES
Chris@16:                 mark_finished_with_result_internal(boost::forward<T>(result_), lock);
Chris@16: #else
Chris@16:                 mark_finished_with_result_internal(static_cast<rvalue_source_type>(result_), lock);
Chris@16: #endif
Chris@16:             }
Chris@16: 
Chris@16:             virtual move_dest_type get()
Chris@16:             {
Chris@16:                 wait();
Chris@16:                 return boost::move(*result);
Chris@16:             }
Chris@16: 
Chris@16:             virtual shared_future_get_result_type get_sh()
Chris@16:             {
Chris@16:                 wait();
Chris@16:                 return *result;
Chris@16:             }
Chris@16: 
Chris@16:             //void set_value_at_thread_exit(const T & result_)
Chris@16:             void set_value_at_thread_exit(source_reference_type result_)
Chris@16:             {
Chris@16:               unique_lock<boost::mutex> lk(this->mutex);
Chris@16:               if (this->has_value(lk))
Chris@16:               {
Chris@16:                   throw_exception(promise_already_satisfied());
Chris@16:               }
Chris@16:               //future_traits<T>::init(result,result_);
Chris@16:               result.reset(new T(result_));
Chris@16: 
Chris@16:               this->is_constructed = true;
Chris@16:               detail::make_ready_at_thread_exit(shared_from_this());
Chris@16:             }
Chris@16:             //void set_value_at_thread_exit(BOOST_THREAD_RV_REF(T) result_)
Chris@16:             void set_value_at_thread_exit(rvalue_source_type result_)
Chris@16:             {
Chris@16:               unique_lock<boost::mutex> lk(this->mutex);
Chris@16:               if (this->has_value(lk))
Chris@16:                   throw_exception(promise_already_satisfied());
Chris@16:               result.reset(new T(boost::move(result_)));
Chris@16:               //future_traits<T>::init(result,static_cast<rvalue_source_type>(result_));
Chris@16:               this->is_constructed = true;
Chris@16:               detail::make_ready_at_thread_exit(shared_from_this());
Chris@16:             }
Chris@16: 
Chris@16: 
Chris@16:         private:
Chris@16:             shared_state(shared_state const&);
Chris@16:             shared_state& operator=(shared_state const&);
Chris@16:         };
Chris@16: 
Chris@16:         template<typename T>
Chris@16:         struct shared_state<T&>:
Chris@16:             detail::shared_state_base
Chris@16:         {
Chris@16:             typedef typename future_traits<T&>::storage_type storage_type;
Chris@16:             typedef typename future_traits<T&>::source_reference_type source_reference_type;
Chris@16:             typedef typename future_traits<T&>::move_dest_type move_dest_type;
Chris@16:             typedef typename future_traits<T&>::shared_future_get_result_type shared_future_get_result_type;
Chris@16: 
Chris@16:             T* result;
Chris@16: 
Chris@16:             shared_state():
Chris@16:                 result(0)
Chris@16:             {}
Chris@16: 
Chris@16:             ~shared_state()
Chris@16:             {
Chris@16:             }
Chris@16: 
Chris@16:             void mark_finished_with_result_internal(source_reference_type result_, boost::unique_lock<boost::mutex>& lock)
Chris@16:             {
Chris@16:                 //future_traits<T>::init(result,result_);
Chris@16:                 result= &result_;
Chris@16:                 mark_finished_internal(lock);
Chris@16:             }
Chris@16: 
Chris@16:             void mark_finished_with_result(source_reference_type result_)
Chris@16:             {
Chris@16:                 boost::unique_lock<boost::mutex> lock(mutex);
Chris@16:                 mark_finished_with_result_internal(result_, lock);
Chris@16:             }
Chris@16: 
Chris@16:             virtual T& get()
Chris@16:             {
Chris@16:                 wait();
Chris@16:                 return *result;
Chris@16:             }
Chris@16: 
Chris@16:             virtual T& get_sh()
Chris@16:             {
Chris@16:                 wait();
Chris@16:                 return *result;
Chris@16:             }
Chris@16: 
Chris@16:             void set_value_at_thread_exit(T& result_)
Chris@16:             {
Chris@16:               unique_lock<boost::mutex> lk(this->mutex);
Chris@16:               if (this->has_value(lk))
Chris@16:                   throw_exception(promise_already_satisfied());
Chris@16:               //future_traits<T>::init(result,result_);
Chris@16:               result= &result_;
Chris@16:               this->is_constructed = true;
Chris@16:               detail::make_ready_at_thread_exit(shared_from_this());
Chris@16:             }
Chris@16: 
Chris@16:         private:
Chris@16:             shared_state(shared_state const&);
Chris@16:             shared_state& operator=(shared_state const&);
Chris@16:         };
Chris@16: 
Chris@16:         template<>
Chris@16:         struct shared_state<void>:
Chris@16:             detail::shared_state_base
Chris@16:         {
Chris@16:           typedef void shared_future_get_result_type;
Chris@16: 
Chris@16:             shared_state()
Chris@16:             {}
Chris@16: 
Chris@16:             void mark_finished_with_result_internal(boost::unique_lock<boost::mutex>& lock)
Chris@16:             {
Chris@16:                 mark_finished_internal(lock);
Chris@16:             }
Chris@16: 
Chris@16:             void mark_finished_with_result()
Chris@16:             {
Chris@16:                 boost::unique_lock<boost::mutex> lock(mutex);
Chris@16:                 mark_finished_with_result_internal(lock);
Chris@16:             }
Chris@16: 
Chris@16:             virtual void get()
Chris@16:             {
Chris@16:                 this->wait();
Chris@16:             }
Chris@16: 
Chris@16:             virtual void get_sh()
Chris@16:             {
Chris@16:                 wait();
Chris@16:             }
Chris@16: 
Chris@16:             void set_value_at_thread_exit()
Chris@16:             {
Chris@16:               unique_lock<boost::mutex> lk(this->mutex);
Chris@16:               if (this->has_value(lk))
Chris@16:               {
Chris@16:                   throw_exception(promise_already_satisfied());
Chris@16:               }
Chris@16:               this->is_constructed = true;
Chris@16:               detail::make_ready_at_thread_exit(shared_from_this());
Chris@16:             }
Chris@16:         private:
Chris@16:             shared_state(shared_state const&);
Chris@16:             shared_state& operator=(shared_state const&);
Chris@16:         };
Chris@16: 
Chris@16:         /////////////////////////
Chris@16:         /// future_async_shared_state_base
Chris@16:         /////////////////////////
Chris@16:         template<typename Rp>
Chris@16:         struct future_async_shared_state_base: shared_state<Rp>
Chris@16:         {
Chris@16:           typedef shared_state<Rp> base_type;
Chris@16:         protected:
Chris@16:           boost::thread thr_;
Chris@16:           void join()
Chris@16:           {
Chris@16:               if (thr_.joinable()) thr_.join();
Chris@16:           }
Chris@16:         public:
Chris@16:           future_async_shared_state_base()
Chris@16:           {
Chris@16:             this->set_async();
Chris@16:           }
Chris@16:           explicit future_async_shared_state_base(BOOST_THREAD_RV_REF(boost::thread) th) :
Chris@16:             thr_(boost::move(th))
Chris@16:           {
Chris@16:             this->set_async();
Chris@16:           }
Chris@16: 
Chris@16:           ~future_async_shared_state_base()
Chris@16:           {
Chris@16:             join();
Chris@16:           }
Chris@16: 
Chris@16:           virtual void wait(bool rethrow)
Chris@16:           {
Chris@16:               join();
Chris@16:               this->base_type::wait(rethrow);
Chris@16:           }
Chris@16:         };
Chris@16: 
Chris@16:         /////////////////////////
Chris@16:         /// future_async_shared_state
Chris@16:         /////////////////////////
Chris@16:         template<typename Rp, typename Fp>
Chris@16:         struct future_async_shared_state: future_async_shared_state_base<Rp>
Chris@16:         {
Chris@16:           typedef future_async_shared_state_base<Rp> base_type;
Chris@16: 
Chris@16:         public:
Chris@16:           explicit future_async_shared_state(BOOST_THREAD_FWD_REF(Fp) f) :
Chris@16:           base_type(thread(&future_async_shared_state::run, this, boost::forward<Fp>(f)))
Chris@16:           {
Chris@16:           }
Chris@16: 
Chris@16:           static void run(future_async_shared_state* that, BOOST_THREAD_FWD_REF(Fp) f)
Chris@16:           {
Chris@16:             try
Chris@16:             {
Chris@16:               that->mark_finished_with_result(f());
Chris@16:             }
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:             catch(thread_interrupted& )
Chris@16:             {
Chris@16:               that->mark_interrupted_finish();
Chris@16:             }
Chris@16: #endif
Chris@16:             catch(...)
Chris@16:             {
Chris@16:               that->mark_exceptional_finish();
Chris@16:             }
Chris@16:           }
Chris@16:         };
Chris@16: 
Chris@16:         template<typename Fp>
Chris@16:         struct future_async_shared_state<void, Fp>: public future_async_shared_state_base<void>
Chris@16:         {
Chris@16:           typedef future_async_shared_state_base<void> base_type;
Chris@16: 
Chris@16:         public:
Chris@16:           explicit future_async_shared_state(BOOST_THREAD_FWD_REF(Fp) f) :
Chris@16:           base_type(thread(&future_async_shared_state::run, this, boost::forward<Fp>(f)))
Chris@16:           {
Chris@16:           }
Chris@16: 
Chris@16:           static void run(future_async_shared_state* that, BOOST_THREAD_FWD_REF(Fp) f)
Chris@16:           {
Chris@16:             try
Chris@16:             {
Chris@16:               f();
Chris@16:               that->mark_finished_with_result();
Chris@16:             }
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:             catch(thread_interrupted& )
Chris@16:             {
Chris@16:               that->mark_interrupted_finish();
Chris@16:             }
Chris@16: #endif
Chris@16:             catch(...)
Chris@16:             {
Chris@16:               that->mark_exceptional_finish();
Chris@16:             }
Chris@16:           }
Chris@16:         };
Chris@16: 
Chris@16:         template<typename Rp, typename Fp>
Chris@16:         struct future_async_shared_state<Rp&, Fp>: future_async_shared_state_base<Rp&>
Chris@16:         {
Chris@16:           typedef future_async_shared_state_base<Rp&> base_type;
Chris@16: 
Chris@16:         public:
Chris@16:           explicit future_async_shared_state(BOOST_THREAD_FWD_REF(Fp) f) :
Chris@16:           base_type(thread(&future_async_shared_state::run, this, boost::forward<Fp>(f)))
Chris@16:           {
Chris@16:           }
Chris@16: 
Chris@16:           static void run(future_async_shared_state* that, BOOST_THREAD_FWD_REF(Fp) f)
Chris@16:           {
Chris@16:             try
Chris@16:             {
Chris@16:               that->mark_finished_with_result(f());
Chris@16:             }
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:             catch(thread_interrupted& )
Chris@16:             {
Chris@16:               that->mark_interrupted_finish();
Chris@16:             }
Chris@16: #endif
Chris@16:             catch(...)
Chris@16:             {
Chris@16:               that->mark_exceptional_finish();
Chris@16:             }
Chris@16:           }
Chris@16:         };
Chris@16: 
Chris@16:         //////////////////////////
Chris@16:         /// future_deferred_shared_state
Chris@16:         //////////////////////////
Chris@16:         template<typename Rp, typename Fp>
Chris@16:         struct future_deferred_shared_state: shared_state<Rp>
Chris@16:         {
Chris@16:           typedef shared_state<Rp> base_type;
Chris@16:           Fp func_;
Chris@16: 
Chris@16:         public:
Chris@16:           explicit future_deferred_shared_state(BOOST_THREAD_FWD_REF(Fp) f)
Chris@16:           : func_(boost::forward<Fp>(f))
Chris@16:           {
Chris@16:             this->set_deferred();
Chris@16:           }
Chris@16: 
Chris@16:           virtual void execute(boost::unique_lock<boost::mutex>& lck) {
Chris@16:             try
Chris@16:             {
Chris@16:               Fp local_fuct=boost::move(func_);
Chris@16:               relocker relock(lck);
Chris@16:               Rp res = local_fuct();
Chris@16:               relock.lock();
Chris@16:               this->mark_finished_with_result_internal(boost::move(res), lck);
Chris@16:             }
Chris@16:             catch (...)
Chris@16:             {
Chris@16:               this->mark_exceptional_finish_internal(current_exception(), lck);
Chris@16:             }
Chris@16:           }
Chris@16:         };
Chris@16:         template<typename Rp, typename Fp>
Chris@16:         struct future_deferred_shared_state<Rp&,Fp>: shared_state<Rp&>
Chris@16:         {
Chris@16:           typedef shared_state<Rp&> base_type;
Chris@16:           Fp func_;
Chris@16: 
Chris@16:         public:
Chris@16:           explicit future_deferred_shared_state(BOOST_THREAD_FWD_REF(Fp) f)
Chris@16:           : func_(boost::forward<Fp>(f))
Chris@16:           {
Chris@16:             this->set_deferred();
Chris@16:           }
Chris@16: 
Chris@16:           virtual void execute(boost::unique_lock<boost::mutex>& lck) {
Chris@16:             try
Chris@16:             {
Chris@16:               this->mark_finished_with_result_internal(func_(), lck);
Chris@16:             }
Chris@16:             catch (...)
Chris@16:             {
Chris@16:               this->mark_exceptional_finish_internal(current_exception(), lck);
Chris@16:             }
Chris@16:           }
Chris@16:         };
Chris@16: 
Chris@16:         template<typename Fp>
Chris@16:         struct future_deferred_shared_state<void,Fp>: shared_state<void>
Chris@16:         {
Chris@16:           typedef shared_state<void> base_type;
Chris@16:           Fp func_;
Chris@16: 
Chris@16:         public:
Chris@16:           explicit future_deferred_shared_state(BOOST_THREAD_FWD_REF(Fp) f)
Chris@16:           : func_(boost::forward<Fp>(f))
Chris@16:           {
Chris@16:             this->set_deferred();
Chris@16:           }
Chris@16: 
Chris@16:           virtual void execute(boost::unique_lock<boost::mutex>& lck) {
Chris@16:             try
Chris@16:             {
Chris@16:               Fp local_fuct=boost::move(func_);
Chris@16:               relocker relock(lck);
Chris@16:               local_fuct();
Chris@16:               relock.lock();
Chris@16:               this->mark_finished_with_result_internal(lck);
Chris@16:             }
Chris@16:             catch (...)
Chris@16:             {
Chris@16:               this->mark_exceptional_finish_internal(current_exception(), lck);
Chris@16:             }
Chris@16:           }
Chris@16:         };
Chris@16: 
Chris@16: //        template<typename T, typename Allocator>
Chris@16: //        struct shared_state_alloc: public shared_state<T>
Chris@16: //        {
Chris@16: //          typedef shared_state<T> base;
Chris@16: //          Allocator alloc_;
Chris@16: //
Chris@16: //        public:
Chris@16: //          explicit shared_state_alloc(const Allocator& a)
Chris@16: //              : alloc_(a) {}
Chris@16: //
Chris@16: //        };
Chris@16:         class future_waiter
Chris@16:         {
Chris@16:             struct registered_waiter;
Chris@16:             typedef std::vector<int>::size_type count_type;
Chris@16: 
Chris@16:             struct registered_waiter
Chris@16:             {
Chris@16:                 boost::shared_ptr<detail::shared_state_base> future_;
Chris@16:                 detail::shared_state_base::waiter_list::iterator wait_iterator;
Chris@16:                 count_type index;
Chris@16: 
Chris@16:                 registered_waiter(boost::shared_ptr<detail::shared_state_base> const& a_future,
Chris@16:                                   detail::shared_state_base::waiter_list::iterator wait_iterator_,
Chris@16:                                   count_type index_):
Chris@16:                     future_(a_future),wait_iterator(wait_iterator_),index(index_)
Chris@16:                 {}
Chris@16:             };
Chris@16: 
Chris@16:             struct all_futures_lock
Chris@16:             {
Chris@16: #ifdef _MANAGED
Chris@16:                    typedef std::ptrdiff_t count_type_portable;
Chris@16: #else
Chris@16:                    typedef count_type count_type_portable;
Chris@16: #endif
Chris@16:                    count_type_portable count;
Chris@16:                    boost::scoped_array<boost::unique_lock<boost::mutex> > locks;
Chris@16: 
Chris@16:                 all_futures_lock(std::vector<registered_waiter>& futures):
Chris@16:                     count(futures.size()),locks(new boost::unique_lock<boost::mutex>[count])
Chris@16:                 {
Chris@16:                     for(count_type_portable i=0;i<count;++i)
Chris@16:                     {
Chris@16: #if defined __DECCXX || defined __SUNPRO_CC || defined __hpux
Chris@16:                         locks[i]=boost::unique_lock<boost::mutex>(futures[i].future_->mutex).move();
Chris@16: #else
Chris@16:                         locks[i]=boost::unique_lock<boost::mutex>(futures[i].future_->mutex);
Chris@16: #endif
Chris@16:                     }
Chris@16:                 }
Chris@16: 
Chris@16:                 void lock()
Chris@16:                 {
Chris@16:                     boost::lock(locks.get(),locks.get()+count);
Chris@16:                 }
Chris@16: 
Chris@16:                 void unlock()
Chris@16:                 {
Chris@16:                     for(count_type_portable i=0;i<count;++i)
Chris@16:                     {
Chris@16:                         locks[i].unlock();
Chris@16:                     }
Chris@16:                 }
Chris@16:             };
Chris@16: 
Chris@16:             boost::condition_variable_any cv;
Chris@16:             std::vector<registered_waiter> futures;
Chris@16:             count_type future_count;
Chris@16: 
Chris@16:         public:
Chris@16:             future_waiter():
Chris@16:                 future_count(0)
Chris@16:             {}
Chris@16: 
Chris@16:             template<typename F>
Chris@16:             void add(F& f)
Chris@16:             {
Chris@16:                 if(f.future_)
Chris@16:                 {
Chris@16:                     futures.push_back(registered_waiter(f.future_,f.future_->register_external_waiter(cv),future_count));
Chris@16:                 }
Chris@16:                 ++future_count;
Chris@16:             }
Chris@16: 
Chris@16:             count_type wait()
Chris@16:             {
Chris@16:                 all_futures_lock lk(futures);
Chris@16:                 for(;;)
Chris@16:                 {
Chris@16:                     for(count_type i=0;i<futures.size();++i)
Chris@16:                     {
Chris@16:                         if(futures[i].future_->done)
Chris@16:                         {
Chris@16:                             return futures[i].index;
Chris@16:                         }
Chris@16:                     }
Chris@16:                     cv.wait(lk);
Chris@16:                 }
Chris@16:             }
Chris@16: 
Chris@16:             ~future_waiter()
Chris@16:             {
Chris@16:                 for(count_type i=0;i<futures.size();++i)
Chris@16:                 {
Chris@16:                     futures[i].future_->remove_external_waiter(futures[i].wait_iterator);
Chris@16:                 }
Chris@16:             }
Chris@16: 
Chris@16:         };
Chris@16: 
Chris@16:     }
Chris@16: 
Chris@16:     template <typename R>
Chris@16:     class BOOST_THREAD_FUTURE;
Chris@16: 
Chris@16:     template <typename R>
Chris@16:     class shared_future;
Chris@16: 
Chris@16:     template<typename T>
Chris@16:     struct is_future_type
Chris@16:     {
Chris@16:         BOOST_STATIC_CONSTANT(bool, value=false);
Chris@16:         typedef void type;
Chris@16:     };
Chris@16: 
Chris@16:     template<typename T>
Chris@16:     struct is_future_type<BOOST_THREAD_FUTURE<T> >
Chris@16:     {
Chris@16:         BOOST_STATIC_CONSTANT(bool, value=true);
Chris@16:         typedef T type;
Chris@16:     };
Chris@16: 
Chris@16:     template<typename T>
Chris@16:     struct is_future_type<shared_future<T> >
Chris@16:     {
Chris@16:         BOOST_STATIC_CONSTANT(bool, value=true);
Chris@16:         typedef T type;
Chris@16:     };
Chris@16: 
Chris@16:     template<typename Iterator>
Chris@16:     typename boost::disable_if<is_future_type<Iterator>,void>::type wait_for_all(Iterator begin,Iterator end)
Chris@16:     {
Chris@16:         for(Iterator current=begin;current!=end;++current)
Chris@16:         {
Chris@16:             current->wait();
Chris@16:         }
Chris@16:     }
Chris@16: 
Chris@16:     template<typename F1,typename F2>
Chris@16:     typename boost::enable_if<is_future_type<F1>,void>::type wait_for_all(F1& f1,F2& f2)
Chris@16:     {
Chris@16:         f1.wait();
Chris@16:         f2.wait();
Chris@16:     }
Chris@16: 
Chris@16:     template<typename F1,typename F2,typename F3>
Chris@16:     void wait_for_all(F1& f1,F2& f2,F3& f3)
Chris@16:     {
Chris@16:         f1.wait();
Chris@16:         f2.wait();
Chris@16:         f3.wait();
Chris@16:     }
Chris@16: 
Chris@16:     template<typename F1,typename F2,typename F3,typename F4>
Chris@16:     void wait_for_all(F1& f1,F2& f2,F3& f3,F4& f4)
Chris@16:     {
Chris@16:         f1.wait();
Chris@16:         f2.wait();
Chris@16:         f3.wait();
Chris@16:         f4.wait();
Chris@16:     }
Chris@16: 
Chris@16:     template<typename F1,typename F2,typename F3,typename F4,typename F5>
Chris@16:     void wait_for_all(F1& f1,F2& f2,F3& f3,F4& f4,F5& f5)
Chris@16:     {
Chris@16:         f1.wait();
Chris@16:         f2.wait();
Chris@16:         f3.wait();
Chris@16:         f4.wait();
Chris@16:         f5.wait();
Chris@16:     }
Chris@16: 
Chris@16:     template<typename Iterator>
Chris@16:     typename boost::disable_if<is_future_type<Iterator>,Iterator>::type wait_for_any(Iterator begin,Iterator end)
Chris@16:     {
Chris@16:         if(begin==end)
Chris@16:             return end;
Chris@16: 
Chris@16:         detail::future_waiter waiter;
Chris@16:         for(Iterator current=begin;current!=end;++current)
Chris@16:         {
Chris@16:             waiter.add(*current);
Chris@16:         }
Chris@16:         return boost::next(begin,waiter.wait());
Chris@16:     }
Chris@16: 
Chris@16:     template<typename F1,typename F2>
Chris@16:     typename boost::enable_if<is_future_type<F1>,unsigned>::type wait_for_any(F1& f1,F2& f2)
Chris@16:     {
Chris@16:         detail::future_waiter waiter;
Chris@16:         waiter.add(f1);
Chris@16:         waiter.add(f2);
Chris@16:         return waiter.wait();
Chris@16:     }
Chris@16: 
Chris@16:     template<typename F1,typename F2,typename F3>
Chris@16:     unsigned wait_for_any(F1& f1,F2& f2,F3& f3)
Chris@16:     {
Chris@16:         detail::future_waiter waiter;
Chris@16:         waiter.add(f1);
Chris@16:         waiter.add(f2);
Chris@16:         waiter.add(f3);
Chris@16:         return waiter.wait();
Chris@16:     }
Chris@16: 
Chris@16:     template<typename F1,typename F2,typename F3,typename F4>
Chris@16:     unsigned wait_for_any(F1& f1,F2& f2,F3& f3,F4& f4)
Chris@16:     {
Chris@16:         detail::future_waiter waiter;
Chris@16:         waiter.add(f1);
Chris@16:         waiter.add(f2);
Chris@16:         waiter.add(f3);
Chris@16:         waiter.add(f4);
Chris@16:         return waiter.wait();
Chris@16:     }
Chris@16: 
Chris@16:     template<typename F1,typename F2,typename F3,typename F4,typename F5>
Chris@16:     unsigned wait_for_any(F1& f1,F2& f2,F3& f3,F4& f4,F5& f5)
Chris@16:     {
Chris@16:         detail::future_waiter waiter;
Chris@16:         waiter.add(f1);
Chris@16:         waiter.add(f2);
Chris@16:         waiter.add(f3);
Chris@16:         waiter.add(f4);
Chris@16:         waiter.add(f5);
Chris@16:         return waiter.wait();
Chris@16:     }
Chris@16: 
Chris@16:     template <typename R>
Chris@16:     class promise;
Chris@16: 
Chris@16:     template <typename R>
Chris@16:     class packaged_task;
Chris@16: 
Chris@16:     namespace detail
Chris@16:     {
Chris@16:       /// Common implementation for all the futures independently of the return type
Chris@16:       class base_future
Chris@16:       {
Chris@16:         //BOOST_THREAD_MOVABLE(base_future)
Chris@16: 
Chris@16:       };
Chris@16:       /// Common implementation for future and shared_future.
Chris@16:       template <typename R>
Chris@16:       class basic_future : public base_future
Chris@16:       {
Chris@16:       protected:
Chris@16:       public:
Chris@16: 
Chris@16:         typedef boost::shared_ptr<detail::shared_state<R> > future_ptr;
Chris@16: 
Chris@16:         future_ptr future_;
Chris@16: 
Chris@16:         basic_future(future_ptr a_future):
Chris@16:           future_(a_future)
Chris@16:         {
Chris@16:         }
Chris@16:         // Copy construction from a shared_future
Chris@16:         explicit basic_future(const shared_future<R>&) BOOST_NOEXCEPT;
Chris@16: 
Chris@16:       public:
Chris@16:         typedef future_state::state state;
Chris@16: 
Chris@16:         BOOST_THREAD_MOVABLE(basic_future)
Chris@16:         basic_future(): future_() {}
Chris@16:         ~basic_future() {}
Chris@16: 
Chris@16:         basic_future(BOOST_THREAD_RV_REF(basic_future) other) BOOST_NOEXCEPT:
Chris@16:         future_(BOOST_THREAD_RV(other).future_)
Chris@16:         {
Chris@16:             BOOST_THREAD_RV(other).future_.reset();
Chris@16:         }
Chris@16:         basic_future& operator=(BOOST_THREAD_RV_REF(basic_future) other) BOOST_NOEXCEPT
Chris@16:         {
Chris@16:             future_=BOOST_THREAD_RV(other).future_;
Chris@16:             BOOST_THREAD_RV(other).future_.reset();
Chris@16:             return *this;
Chris@16:         }
Chris@16:         void swap(basic_future& that) BOOST_NOEXCEPT
Chris@16:         {
Chris@16:           future_.swap(that.future_);
Chris@16:         }
Chris@16:         // functions to check state, and wait for ready
Chris@16:         state get_state() const
Chris@16:         {
Chris@16:             if(!future_)
Chris@16:             {
Chris@16:                 return future_state::uninitialized;
Chris@16:             }
Chris@16:             return future_->get_state();
Chris@16:         }
Chris@16: 
Chris@16:         bool is_ready() const
Chris@16:         {
Chris@16:             return get_state()==future_state::ready;
Chris@16:         }
Chris@16: 
Chris@16:         bool has_exception() const
Chris@16:         {
Chris@16:             return future_ && future_->has_exception();
Chris@16:         }
Chris@16: 
Chris@16:         bool has_value() const
Chris@16:         {
Chris@16:             return future_ && future_->has_value();
Chris@16:         }
Chris@16: 
Chris@16:         launch launch_policy(boost::unique_lock<boost::mutex>& lk) const
Chris@16:         {
Chris@16:             if ( future_ ) return future_->launch_policy(lk);
Chris@16:             else return launch(launch::none);
Chris@16:         }
Chris@16: 
Chris@16:         exception_ptr get_exception_ptr()
Chris@16:         {
Chris@16:             return future_
Chris@16:                 ? future_->get_exception_ptr()
Chris@16:                 : exception_ptr();
Chris@16:         }
Chris@16: 
Chris@16:         bool valid() const BOOST_NOEXCEPT
Chris@16:         {
Chris@16:             return future_ != 0;
Chris@16:         }
Chris@16: 
Chris@16: 
Chris@16:         void wait() const
Chris@16:         {
Chris@16:             if(!future_)
Chris@16:             {
Chris@16:                 boost::throw_exception(future_uninitialized());
Chris@16:             }
Chris@16:             future_->wait(false);
Chris@16:         }
Chris@16: 
Chris@16: #if defined BOOST_THREAD_USES_DATETIME
Chris@16:         template<typename Duration>
Chris@16:         bool timed_wait(Duration const& rel_time) const
Chris@16:         {
Chris@16:             return timed_wait_until(boost::get_system_time()+rel_time);
Chris@16:         }
Chris@16: 
Chris@16:         bool timed_wait_until(boost::system_time const& abs_time) const
Chris@16:         {
Chris@16:             if(!future_)
Chris@16:             {
Chris@16:                 boost::throw_exception(future_uninitialized());
Chris@16:             }
Chris@16:             return future_->timed_wait_until(abs_time);
Chris@16:         }
Chris@16: #endif
Chris@16: #ifdef BOOST_THREAD_USES_CHRONO
Chris@16:         template <class Rep, class Period>
Chris@16:         future_status
Chris@16:         wait_for(const chrono::duration<Rep, Period>& rel_time) const
Chris@16:         {
Chris@16:           return wait_until(chrono::steady_clock::now() + rel_time);
Chris@16: 
Chris@16:         }
Chris@16:         template <class Clock, class Duration>
Chris@16:         future_status
Chris@16:         wait_until(const chrono::time_point<Clock, Duration>& abs_time) const
Chris@16:         {
Chris@16:           if(!future_)
Chris@16:           {
Chris@16:               boost::throw_exception(future_uninitialized());
Chris@16:           }
Chris@16:           return future_->wait_until(abs_time);
Chris@16:         }
Chris@16: #endif
Chris@16: 
Chris@16:       };
Chris@16: 
Chris@16:     } // detail
Chris@16:     BOOST_THREAD_DCL_MOVABLE_BEG(R) detail::basic_future<R> BOOST_THREAD_DCL_MOVABLE_END
Chris@16: 
Chris@16:     namespace detail
Chris@16:     {
Chris@16: #if (!defined _MSC_VER || _MSC_VER >= 1400) // _MSC_VER == 1400 on MSVC 2005
Chris@16:         template <class Rp, class Fp>
Chris@16:         BOOST_THREAD_FUTURE<Rp>
Chris@16:         make_future_async_shared_state(BOOST_THREAD_FWD_REF(Fp) f);
Chris@16: 
Chris@16:         template <class Rp, class Fp>
Chris@16:         BOOST_THREAD_FUTURE<Rp>
Chris@16:         make_future_deferred_shared_state(BOOST_THREAD_FWD_REF(Fp) f);
Chris@16: #endif // #if (!defined _MSC_VER || _MSC_VER >= 1400)
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION
Chris@16:         template<typename F, typename Rp, typename Fp>
Chris@16:         struct future_deferred_continuation_shared_state;
Chris@16:         template<typename F, typename Rp, typename Fp>
Chris@16:         struct future_async_continuation_shared_state;
Chris@16: 
Chris@16:         template <class F, class Rp, class Fp>
Chris@16:         BOOST_THREAD_FUTURE<Rp>
Chris@16:         make_future_async_continuation_shared_state(boost::unique_lock<boost::mutex> &lock, BOOST_THREAD_RV_REF(F) f, BOOST_THREAD_FWD_REF(Fp) c);
Chris@16: 
Chris@16:         template <class F, class Rp, class Fp>
Chris@16:         BOOST_THREAD_FUTURE<Rp>
Chris@16:         make_future_deferred_continuation_shared_state(boost::unique_lock<boost::mutex> &lock, BOOST_THREAD_RV_REF(F) f, BOOST_THREAD_FWD_REF(Fp) c);
Chris@16: #endif
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_UNWRAP
Chris@16:         template<typename F, typename Rp>
Chris@16:         struct future_unwrap_shared_state;
Chris@16:         template <class F, class Rp>
Chris@16:         inline BOOST_THREAD_FUTURE<Rp>
Chris@16:         make_future_unwrap_shared_state(boost::unique_lock<boost::mutex> &lock, BOOST_THREAD_RV_REF(F) f);
Chris@16: #endif
Chris@16:     }
Chris@16: 
Chris@16:     template <typename R>
Chris@16:     class BOOST_THREAD_FUTURE : public detail::basic_future<R>
Chris@16:     {
Chris@16:     private:
Chris@16:         typedef detail::basic_future<R> base_type;
Chris@16:         typedef typename base_type::future_ptr future_ptr;
Chris@16: 
Chris@16:         friend class shared_future<R>;
Chris@16:         friend class promise<R>;
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION
Chris@16:         template <typename, typename, typename>
Chris@16:         friend struct detail::future_async_continuation_shared_state;
Chris@16:         template <typename, typename, typename>
Chris@16:         friend struct detail::future_deferred_continuation_shared_state;
Chris@16: 
Chris@16:         template <class F, class Rp, class Fp>
Chris@16:         friend BOOST_THREAD_FUTURE<Rp>
Chris@16:         detail::make_future_async_continuation_shared_state(boost::unique_lock<boost::mutex> &lock, BOOST_THREAD_RV_REF(F) f, BOOST_THREAD_FWD_REF(Fp) c);
Chris@16: 
Chris@16:         template <class F, class Rp, class Fp>
Chris@16:         friend BOOST_THREAD_FUTURE<Rp>
Chris@16:         detail::make_future_deferred_continuation_shared_state(boost::unique_lock<boost::mutex> &lock, BOOST_THREAD_RV_REF(F) f, BOOST_THREAD_FWD_REF(Fp) c);
Chris@16: #endif
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_UNWRAP
Chris@16:         template<typename F, typename Rp>
Chris@16:         friend struct detail::future_unwrap_shared_state;
Chris@16:         template <class F, class Rp>
Chris@16:         friend BOOST_THREAD_FUTURE<Rp>
Chris@16:         detail::make_future_unwrap_shared_state(boost::unique_lock<boost::mutex> &lock, BOOST_THREAD_RV_REF(F) f);
Chris@16: #endif
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16:         template <class> friend class packaged_task; // todo check if this works in windows
Chris@16: #else
Chris@16:         friend class packaged_task<R>;
Chris@16: #endif
Chris@16:         friend class detail::future_waiter;
Chris@16: 
Chris@16:         template <class Rp, class Fp>
Chris@16:         friend BOOST_THREAD_FUTURE<Rp>
Chris@16:         detail::make_future_async_shared_state(BOOST_THREAD_FWD_REF(Fp) f);
Chris@16: 
Chris@16:         template <class Rp, class Fp>
Chris@16:         friend BOOST_THREAD_FUTURE<Rp>
Chris@16:         detail::make_future_deferred_shared_state(BOOST_THREAD_FWD_REF(Fp) f);
Chris@16: 
Chris@16: 
Chris@16:         typedef typename detail::future_traits<R>::move_dest_type move_dest_type;
Chris@16: 
Chris@16:         BOOST_THREAD_FUTURE(future_ptr a_future):
Chris@16:           base_type(a_future)
Chris@16:         {
Chris@16:         }
Chris@16: 
Chris@16:     public:
Chris@16:         BOOST_THREAD_MOVABLE_ONLY(BOOST_THREAD_FUTURE)
Chris@16:         typedef future_state::state state;
Chris@16:         typedef R value_type; // EXTENSION
Chris@16: 
Chris@16:         BOOST_CONSTEXPR BOOST_THREAD_FUTURE() {}
Chris@16: 
Chris@16:         ~BOOST_THREAD_FUTURE() {}
Chris@16: 
Chris@16:         BOOST_THREAD_FUTURE(BOOST_THREAD_RV_REF(BOOST_THREAD_FUTURE) other) BOOST_NOEXCEPT:
Chris@16:         base_type(boost::move(static_cast<base_type&>(BOOST_THREAD_RV(other))))
Chris@16:         {
Chris@16:         }
Chris@16:         inline BOOST_THREAD_FUTURE(BOOST_THREAD_RV_REF(BOOST_THREAD_FUTURE<BOOST_THREAD_FUTURE<R> >) other); // EXTENSION
Chris@16: 
Chris@16:         BOOST_THREAD_FUTURE& operator=(BOOST_THREAD_RV_REF(BOOST_THREAD_FUTURE) other) BOOST_NOEXCEPT
Chris@16:         {
Chris@16:             this->base_type::operator=(boost::move(static_cast<base_type&>(BOOST_THREAD_RV(other))));
Chris@16:             return *this;
Chris@16:         }
Chris@16: 
Chris@16:         shared_future<R> share()
Chris@16:         {
Chris@16:           return shared_future<R>(::boost::move(*this));
Chris@16:         }
Chris@16: 
Chris@16:         void swap(BOOST_THREAD_FUTURE& other)
Chris@16:         {
Chris@16:             static_cast<base_type*>(this)->swap(other);
Chris@16:         }
Chris@16: 
Chris@16:         // todo this function must be private and friendship provided to the internal users.
Chris@16:         void set_async()
Chris@16:         {
Chris@16:           this->future_->set_async();
Chris@16:         }
Chris@16:         // todo this function must be private and friendship provided to the internal users.
Chris@16:         void set_deferred()
Chris@16:         {
Chris@16:           this->future_->set_deferred();
Chris@16:         }
Chris@16: 
Chris@16:         // retrieving the value
Chris@16:         move_dest_type get()
Chris@16:         {
Chris@16:             if(!this->future_)
Chris@16:             {
Chris@16:                 boost::throw_exception(future_uninitialized());
Chris@16:             }
Chris@16:             future_ptr fut_=this->future_;
Chris@16: #ifdef BOOST_THREAD_PROVIDES_FUTURE_INVALID_AFTER_GET
Chris@16:             this->future_.reset();
Chris@16: #endif
Chris@16:             return fut_->get();
Chris@16:         }
Chris@16: 
Chris@16:         template <typename R2>
Chris@16:         typename boost::disable_if< is_void<R2>, move_dest_type>::type
Chris@16:         get_or(BOOST_THREAD_RV_REF(R2) v)
Chris@16:         {
Chris@16:             if(!this->future_)
Chris@16:             {
Chris@16:                 boost::throw_exception(future_uninitialized());
Chris@16:             }
Chris@16:             this->future_->wait(false);
Chris@16:             future_ptr fut_=this->future_;
Chris@16: #ifdef BOOST_THREAD_PROVIDES_FUTURE_INVALID_AFTER_GET
Chris@16:             this->future_.reset();
Chris@16: #endif
Chris@16:             if (fut_->has_value()) {
Chris@16:               return fut_->get();
Chris@16:             }
Chris@16:             else {
Chris@16:               return boost::move(v);
Chris@16:             }
Chris@16:         }
Chris@16: 
Chris@16:         template <typename R2>
Chris@16:         typename boost::disable_if< is_void<R2>, move_dest_type>::type
Chris@16:         get_or(R2 const& v)  // EXTENSION
Chris@16:         {
Chris@16:             if(!this->future_)
Chris@16:             {
Chris@16:                 boost::throw_exception(future_uninitialized());
Chris@16:             }
Chris@16:             this->future_->wait(false);
Chris@16:             future_ptr fut_=this->future_;
Chris@16: #ifdef BOOST_THREAD_PROVIDES_FUTURE_INVALID_AFTER_GET
Chris@16:             this->future_.reset();
Chris@16: #endif
Chris@16:             if (fut_->has_value()) {
Chris@16:               return fut_->get();
Chris@16:             }
Chris@16:             else {
Chris@16:               return v;
Chris@16:             }
Chris@16:         }
Chris@16: 
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION
Chris@16: 
Chris@16: //        template<typename F>
Chris@16: //        auto then(F&& func) -> BOOST_THREAD_FUTURE<decltype(func(*this))>;
Chris@16: 
Chris@16: //#if defined(BOOST_THREAD_RVALUE_REFERENCES_DONT_MATCH_FUNTION_PTR)
Chris@16: //        template<typename RF>
Chris@16: //        inline BOOST_THREAD_FUTURE<RF> then(RF(*func)(BOOST_THREAD_FUTURE&));
Chris@16: //        template<typename RF>
Chris@16: //        inline BOOST_THREAD_FUTURE<RF> then(launch policy, RF(*func)(BOOST_THREAD_FUTURE&));
Chris@16: //#endif
Chris@16:         template<typename F>
Chris@16:         inline BOOST_THREAD_FUTURE<typename boost::result_of<F(BOOST_THREAD_FUTURE)>::type>
Chris@16:         then(BOOST_THREAD_FWD_REF(F) func);  // EXTENSION
Chris@16:         template<typename F>
Chris@16:         inline BOOST_THREAD_FUTURE<typename boost::result_of<F(BOOST_THREAD_FUTURE)>::type>
Chris@16:         then(launch policy, BOOST_THREAD_FWD_REF(F) func);  // EXTENSION
Chris@16: 
Chris@16:         template <typename R2>
Chris@16:         inline typename boost::disable_if< is_void<R2>, BOOST_THREAD_FUTURE<R> >::type
Chris@16:         fallback_to(BOOST_THREAD_RV_REF(R2) v);  // EXTENSION
Chris@16:         template <typename R2>
Chris@16:         inline typename boost::disable_if< is_void<R2>, BOOST_THREAD_FUTURE<R> >::type
Chris@16:         fallback_to(R2 const& v);  // EXTENSION
Chris@16: 
Chris@16: #endif
Chris@16: 
Chris@16: //#if defined BOOST_THREAD_PROVIDES_FUTURE_UNWRAP
Chris@16: //        inline
Chris@16: //        typename boost::enable_if<
Chris@16: //          is_future_type<value_type>,
Chris@16: //          value_type
Chris@16: //        //BOOST_THREAD_FUTURE<typename is_future_type<value_type>::type>
Chris@16: //        >::type
Chris@16: //        unwrap();
Chris@16: //#endif
Chris@16: 
Chris@16:     };
Chris@16: 
Chris@16:     BOOST_THREAD_DCL_MOVABLE_BEG(T) BOOST_THREAD_FUTURE<T> BOOST_THREAD_DCL_MOVABLE_END
Chris@16: 
Chris@16:         template <typename R2>
Chris@16:         class BOOST_THREAD_FUTURE<BOOST_THREAD_FUTURE<R2> > : public detail::basic_future<BOOST_THREAD_FUTURE<R2> >
Chris@16:         {
Chris@16:           typedef BOOST_THREAD_FUTURE<R2> R;
Chris@16: 
Chris@16:         private:
Chris@16:             typedef detail::basic_future<R> base_type;
Chris@16:             typedef typename base_type::future_ptr future_ptr;
Chris@16: 
Chris@16:             friend class shared_future<R>;
Chris@16:             friend class promise<R>;
Chris@16:     #if defined BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION
Chris@16:             template <typename, typename, typename>
Chris@16:             friend struct detail::future_async_continuation_shared_state;
Chris@16:             template <typename, typename, typename>
Chris@16:             friend struct detail::future_deferred_continuation_shared_state;
Chris@16: 
Chris@16:             template <class F, class Rp, class Fp>
Chris@16:             friend BOOST_THREAD_FUTURE<Rp>
Chris@16:             detail::make_future_async_continuation_shared_state(boost::unique_lock<boost::mutex> &lock, BOOST_THREAD_RV_REF(F) f, BOOST_THREAD_FWD_REF(Fp) c);
Chris@16: 
Chris@16:             template <class F, class Rp, class Fp>
Chris@16:             friend BOOST_THREAD_FUTURE<Rp>
Chris@16:             detail::make_future_deferred_continuation_shared_state(boost::unique_lock<boost::mutex> &lock, BOOST_THREAD_RV_REF(F) f, BOOST_THREAD_FWD_REF(Fp) c);
Chris@16:     #endif
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_UNWRAP
Chris@16:             template<typename F, typename Rp>
Chris@16:             friend struct detail::future_unwrap_shared_state;
Chris@16:         template <class F, class Rp>
Chris@16:         friend BOOST_THREAD_FUTURE<Rp>
Chris@16:         detail::make_future_unwrap_shared_state(boost::unique_lock<boost::mutex> &lock, BOOST_THREAD_RV_REF(F) f);
Chris@16: #endif
Chris@16:     #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16:             template <class> friend class packaged_task; // todo check if this works in windows
Chris@16:     #else
Chris@16:             friend class packaged_task<R>;
Chris@16:     #endif
Chris@16:             friend class detail::future_waiter;
Chris@16: 
Chris@16:             template <class Rp, class Fp>
Chris@16:             friend BOOST_THREAD_FUTURE<Rp>
Chris@16:             detail::make_future_async_shared_state(BOOST_THREAD_FWD_REF(Fp) f);
Chris@16: 
Chris@16:             template <class Rp, class Fp>
Chris@16:             friend BOOST_THREAD_FUTURE<Rp>
Chris@16:             detail::make_future_deferred_shared_state(BOOST_THREAD_FWD_REF(Fp) f);
Chris@16: 
Chris@16: 
Chris@16:             typedef typename detail::future_traits<R>::move_dest_type move_dest_type;
Chris@16: 
Chris@16:             BOOST_THREAD_FUTURE(future_ptr a_future):
Chris@16:               base_type(a_future)
Chris@16:             {
Chris@16:             }
Chris@16: 
Chris@16:         public:
Chris@16:             BOOST_THREAD_MOVABLE_ONLY(BOOST_THREAD_FUTURE)
Chris@16:             typedef future_state::state state;
Chris@16:             typedef R value_type; // EXTENSION
Chris@16: 
Chris@16:             BOOST_CONSTEXPR BOOST_THREAD_FUTURE() {}
Chris@16: 
Chris@16:             ~BOOST_THREAD_FUTURE() {}
Chris@16: 
Chris@16:             BOOST_THREAD_FUTURE(BOOST_THREAD_RV_REF(BOOST_THREAD_FUTURE) other) BOOST_NOEXCEPT:
Chris@16:             base_type(boost::move(static_cast<base_type&>(BOOST_THREAD_RV(other))))
Chris@16:             {
Chris@16:             }
Chris@16: 
Chris@16:             BOOST_THREAD_FUTURE& operator=(BOOST_THREAD_RV_REF(BOOST_THREAD_FUTURE) other) BOOST_NOEXCEPT
Chris@16:             {
Chris@16:                 this->base_type::operator=(boost::move(static_cast<base_type&>(BOOST_THREAD_RV(other))));
Chris@16:                 return *this;
Chris@16:             }
Chris@16: 
Chris@16:             shared_future<R> share()
Chris@16:             {
Chris@16:               return shared_future<R>(::boost::move(*this));
Chris@16:             }
Chris@16: 
Chris@16:             void swap(BOOST_THREAD_FUTURE& other)
Chris@16:             {
Chris@16:                 static_cast<base_type*>(this)->swap(other);
Chris@16:             }
Chris@16: 
Chris@16:             // todo this function must be private and friendship provided to the internal users.
Chris@16:             void set_async()
Chris@16:             {
Chris@16:               this->future_->set_async();
Chris@16:             }
Chris@16:             // todo this function must be private and friendship provided to the internal users.
Chris@16:             void set_deferred()
Chris@16:             {
Chris@16:               this->future_->set_deferred();
Chris@16:             }
Chris@16: 
Chris@16:             // retrieving the value
Chris@16:             move_dest_type get()
Chris@16:             {
Chris@16:                 if(!this->future_)
Chris@16:                 {
Chris@16:                     boost::throw_exception(future_uninitialized());
Chris@16:                 }
Chris@16:                 future_ptr fut_=this->future_;
Chris@16:     #ifdef BOOST_THREAD_PROVIDES_FUTURE_INVALID_AFTER_GET
Chris@16:                 this->future_.reset();
Chris@16:     #endif
Chris@16:                 return fut_->get();
Chris@16:             }
Chris@16:             move_dest_type get_or(BOOST_THREAD_RV_REF(R) v) // EXTENSION
Chris@16:             {
Chris@16:                 if(!this->future_)
Chris@16:                 {
Chris@16:                     boost::throw_exception(future_uninitialized());
Chris@16:                 }
Chris@16:                 this->future_->wait(false);
Chris@16:                 future_ptr fut_=this->future_;
Chris@16:     #ifdef BOOST_THREAD_PROVIDES_FUTURE_INVALID_AFTER_GET
Chris@16:                 this->future_.reset();
Chris@16:     #endif
Chris@16:                 if (fut_->has_value()) return fut_->get();
Chris@16:                 else return boost::move(v);
Chris@16:             }
Chris@16: 
Chris@16:             move_dest_type get_or(R const& v) // EXTENSION
Chris@16:             {
Chris@16:                 if(!this->future_)
Chris@16:                 {
Chris@16:                     boost::throw_exception(future_uninitialized());
Chris@16:                 }
Chris@16:                 this->future_->wait(false);
Chris@16:                 future_ptr fut_=this->future_;
Chris@16:     #ifdef BOOST_THREAD_PROVIDES_FUTURE_INVALID_AFTER_GET
Chris@16:                 this->future_.reset();
Chris@16:     #endif
Chris@16:                 if (fut_->has_value()) return fut_->get();
Chris@16:                 else return v;
Chris@16:             }
Chris@16: 
Chris@16: 
Chris@16:     #if defined BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION
Chris@16: 
Chris@16:     //        template<typename F>
Chris@16:     //        auto then(F&& func) -> BOOST_THREAD_FUTURE<decltype(func(*this))>;
Chris@16: 
Chris@16:     //#if defined(BOOST_THREAD_RVALUE_REFERENCES_DONT_MATCH_FUNTION_PTR)
Chris@16:     //        template<typename RF>
Chris@16:     //        inline BOOST_THREAD_FUTURE<RF> then(RF(*func)(BOOST_THREAD_FUTURE&));
Chris@16:     //        template<typename RF>
Chris@16:     //        inline BOOST_THREAD_FUTURE<RF> then(launch policy, RF(*func)(BOOST_THREAD_FUTURE&));
Chris@16:     //#endif
Chris@16:             template<typename F>
Chris@16:             inline BOOST_THREAD_FUTURE<typename boost::result_of<F(BOOST_THREAD_FUTURE)>::type>
Chris@16:             then(BOOST_THREAD_FWD_REF(F) func); // EXTENSION
Chris@16:             template<typename F>
Chris@16:             inline BOOST_THREAD_FUTURE<typename boost::result_of<F(BOOST_THREAD_FUTURE)>::type>
Chris@16:             then(launch policy, BOOST_THREAD_FWD_REF(F) func); // EXTENSION
Chris@16:     #endif
Chris@16: 
Chris@16:     #if defined BOOST_THREAD_PROVIDES_FUTURE_UNWRAP
Chris@16:             inline
Chris@16:             BOOST_THREAD_FUTURE<R2>
Chris@16:             unwrap(); // EXTENSION
Chris@16:     #endif
Chris@16: 
Chris@16:   };
Chris@16: 
Chris@16:     template <typename R>
Chris@16:     class shared_future : public detail::basic_future<R>
Chris@16:     {
Chris@16: 
Chris@16:         typedef detail::basic_future<R> base_type;
Chris@16:         typedef typename base_type::future_ptr future_ptr;
Chris@16: 
Chris@16:         friend class detail::future_waiter;
Chris@16:         friend class promise<R>;
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION
Chris@16:         template <typename, typename, typename>
Chris@16:         friend struct detail::future_async_continuation_shared_state;
Chris@16:         template <typename, typename, typename>
Chris@16:         friend struct detail::future_deferred_continuation_shared_state;
Chris@16: 
Chris@16:         template <class F, class Rp, class Fp>
Chris@16:         friend BOOST_THREAD_FUTURE<Rp>
Chris@16:         detail::make_future_async_continuation_shared_state(boost::unique_lock<boost::mutex> &lock, BOOST_THREAD_RV_REF(F) f, BOOST_THREAD_FWD_REF(Fp) c);
Chris@16: 
Chris@16:         template <class F, class Rp, class Fp>
Chris@16:         friend BOOST_THREAD_FUTURE<Rp>
Chris@16:         detail::make_future_deferred_continuation_shared_state(boost::unique_lock<boost::mutex> &lock, BOOST_THREAD_RV_REF(F) f, BOOST_THREAD_FWD_REF(Fp) c);
Chris@16: #endif
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16:         template <class> friend class packaged_task;// todo check if this works in windows
Chris@16: #else
Chris@16:         friend class packaged_task<R>;
Chris@16: #endif
Chris@16:         shared_future(future_ptr a_future):
Chris@16:           base_type(a_future)
Chris@16:         {}
Chris@16: 
Chris@16:     public:
Chris@16:         BOOST_THREAD_MOVABLE(shared_future)
Chris@16:         typedef R value_type; // EXTENSION
Chris@16: 
Chris@16:         shared_future(shared_future const& other):
Chris@16:         base_type(other)
Chris@16:         {}
Chris@16: 
Chris@16:         typedef future_state::state state;
Chris@16: 
Chris@16:         BOOST_CONSTEXPR shared_future()
Chris@16:         {}
Chris@16: 
Chris@16:         ~shared_future()
Chris@16:         {}
Chris@16: 
Chris@16:         shared_future& operator=(shared_future const& other)
Chris@16:         {
Chris@16:             shared_future(other).swap(*this);
Chris@16:             return *this;
Chris@16:         }
Chris@16:         shared_future(BOOST_THREAD_RV_REF(shared_future) other) BOOST_NOEXCEPT :
Chris@16:         base_type(boost::move(static_cast<base_type&>(BOOST_THREAD_RV(other))))
Chris@16:         {
Chris@16:             BOOST_THREAD_RV(other).future_.reset();
Chris@16:         }
Chris@16:         shared_future(BOOST_THREAD_RV_REF( BOOST_THREAD_FUTURE<R> ) other) BOOST_NOEXCEPT :
Chris@16:         base_type(boost::move(static_cast<base_type&>(BOOST_THREAD_RV(other))))
Chris@16:         {
Chris@16:         }
Chris@16: 
Chris@16:         shared_future& operator=(BOOST_THREAD_RV_REF(shared_future) other) BOOST_NOEXCEPT
Chris@16:         {
Chris@16:             base_type::operator=(boost::move(static_cast<base_type&>(BOOST_THREAD_RV(other))));
Chris@16:             return *this;
Chris@16:         }
Chris@16:         shared_future& operator=(BOOST_THREAD_RV_REF( BOOST_THREAD_FUTURE<R> ) other) BOOST_NOEXCEPT
Chris@16:         {
Chris@16:             base_type::operator=(boost::move(static_cast<base_type&>(BOOST_THREAD_RV(other))));
Chris@16:             return *this;
Chris@16:         }
Chris@16: 
Chris@16:         void swap(shared_future& other) BOOST_NOEXCEPT
Chris@16:         {
Chris@16:             static_cast<base_type*>(this)->swap(other);
Chris@16:         }
Chris@16: 
Chris@16:         // retrieving the value
Chris@16:         typename detail::shared_state<R>::shared_future_get_result_type get()
Chris@16:         {
Chris@16:             if(!this->future_)
Chris@16:             {
Chris@16:                 boost::throw_exception(future_uninitialized());
Chris@16:             }
Chris@16: 
Chris@16:             return this->future_->get_sh();
Chris@16:         }
Chris@16: 
Chris@16:         template <typename R2>
Chris@16:         typename boost::disable_if< is_void<R2>, typename detail::shared_state<R>::shared_future_get_result_type>::type
Chris@16:         get_or(BOOST_THREAD_RV_REF(R2) v) // EXTENSION
Chris@16:         {
Chris@16:             if(!this->future_)
Chris@16:             {
Chris@16:                 boost::throw_exception(future_uninitialized());
Chris@16:             }
Chris@16:             future_ptr fut_=this->future_;
Chris@16:             fut_->wait();
Chris@16:             if (fut_->has_value()) return fut_->get_sh();
Chris@16:             else return boost::move(v);
Chris@16:         }
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION
Chris@16: 
Chris@16: //        template<typename F>
Chris@16: //        auto then(F&& func) -> BOOST_THREAD_FUTURE<decltype(func(*this))>;
Chris@16: //        template<typename F>
Chris@16: //        auto then(launch, F&& func) -> BOOST_THREAD_FUTURE<decltype(func(*this))>;
Chris@16: 
Chris@16: //#if defined(BOOST_THREAD_RVALUE_REFERENCES_DONT_MATCH_FUNTION_PTR)
Chris@16: //        template<typename RF>
Chris@16: //        inline BOOST_THREAD_FUTURE<RF> then(RF(*func)(shared_future&));
Chris@16: //        template<typename RF>
Chris@16: //        inline BOOST_THREAD_FUTURE<RF> then(launch policy, RF(*func)(shared_future&));
Chris@16: //#endif
Chris@16:         template<typename F>
Chris@16:         inline BOOST_THREAD_FUTURE<typename boost::result_of<F(shared_future)>::type>
Chris@16:         then(BOOST_THREAD_FWD_REF(F) func); // EXTENSION
Chris@16:         template<typename F>
Chris@16:         inline BOOST_THREAD_FUTURE<typename boost::result_of<F(shared_future)>::type>
Chris@16:         then(launch policy, BOOST_THREAD_FWD_REF(F) func); // EXTENSION
Chris@16: #endif
Chris@16: //#if defined BOOST_THREAD_PROVIDES_FUTURE_UNWRAP
Chris@16: //        inline
Chris@16: //        typename boost::enable_if_c<
Chris@16: //          is_future_type<value_type>::value,
Chris@16: //          BOOST_THREAD_FUTURE<typename is_future_type<value_type>::type>
Chris@16: //        >::type
Chris@16: //        unwrap();
Chris@16: //#endif
Chris@16: 
Chris@16:     };
Chris@16: 
Chris@16:     BOOST_THREAD_DCL_MOVABLE_BEG(T) shared_future<T> BOOST_THREAD_DCL_MOVABLE_END
Chris@16: 
Chris@16:     namespace detail
Chris@16:     {
Chris@16:       /// Copy construction from a shared_future
Chris@16:       template <typename R>
Chris@16:       inline basic_future<R>::basic_future(const shared_future<R>& other) BOOST_NOEXCEPT
Chris@16:       : future_(other.future_)
Chris@16:       {
Chris@16:       }
Chris@16:     }
Chris@16: 
Chris@16:     template <typename R>
Chris@16:     class promise
Chris@16:     {
Chris@16:         typedef boost::shared_ptr<detail::shared_state<R> > future_ptr;
Chris@16: 
Chris@16:         future_ptr future_;
Chris@16:         bool future_obtained;
Chris@16: 
Chris@16:         void lazy_init()
Chris@16:         {
Chris@16: #if defined BOOST_THREAD_PROVIDES_PROMISE_LAZY
Chris@16: #include <boost/detail/atomic_undef_macros.hpp>
Chris@16:           if(!atomic_load(&future_))
Chris@16:             {
Chris@16:                 future_ptr blank;
Chris@16:                 atomic_compare_exchange(&future_,&blank,future_ptr(new detail::shared_state<R>));
Chris@16:             }
Chris@16: #include <boost/detail/atomic_redef_macros.hpp>
Chris@16: #endif
Chris@16:         }
Chris@16: 
Chris@16:     public:
Chris@16:         BOOST_THREAD_MOVABLE_ONLY(promise)
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_CTOR_ALLOCATORS
Chris@16:         template <class Allocator>
Chris@16:         promise(boost::allocator_arg_t, Allocator a)
Chris@16:         {
Chris@16:           typedef typename Allocator::template rebind<detail::shared_state<R> >::other A2;
Chris@16:           A2 a2(a);
Chris@16:           typedef thread_detail::allocator_destructor<A2> D;
Chris@16: 
Chris@16:           future_ = future_ptr(::new(a2.allocate(1)) detail::shared_state<R>(), D(a2, 1) );
Chris@16:           future_obtained = false;
Chris@16:         }
Chris@16: #endif
Chris@16:         promise():
Chris@16: #if defined BOOST_THREAD_PROVIDES_PROMISE_LAZY
Chris@16:             future_(),
Chris@16: #else
Chris@16:             future_(new detail::shared_state<R>()),
Chris@16: #endif
Chris@16:             future_obtained(false)
Chris@16:         {}
Chris@16: 
Chris@16:         ~promise()
Chris@16:         {
Chris@16:             if(future_)
Chris@16:             {
Chris@16:                 boost::unique_lock<boost::mutex> lock(future_->mutex);
Chris@16: 
Chris@16:                 if(!future_->done && !future_->is_constructed)
Chris@16:                 {
Chris@16:                     future_->mark_exceptional_finish_internal(boost::copy_exception(broken_promise()), lock);
Chris@16:                 }
Chris@16:             }
Chris@16:         }
Chris@16: 
Chris@16:         // Assignment
Chris@16:         promise(BOOST_THREAD_RV_REF(promise) rhs) BOOST_NOEXCEPT :
Chris@16:             future_(BOOST_THREAD_RV(rhs).future_),future_obtained(BOOST_THREAD_RV(rhs).future_obtained)
Chris@16:         {
Chris@16:             BOOST_THREAD_RV(rhs).future_.reset();
Chris@16:             BOOST_THREAD_RV(rhs).future_obtained=false;
Chris@16:         }
Chris@16:         promise & operator=(BOOST_THREAD_RV_REF(promise) rhs) BOOST_NOEXCEPT
Chris@16:         {
Chris@16:             future_=BOOST_THREAD_RV(rhs).future_;
Chris@16:             future_obtained=BOOST_THREAD_RV(rhs).future_obtained;
Chris@16:             BOOST_THREAD_RV(rhs).future_.reset();
Chris@16:             BOOST_THREAD_RV(rhs).future_obtained=false;
Chris@16:             return *this;
Chris@16:         }
Chris@16: 
Chris@16:         void swap(promise& other)
Chris@16:         {
Chris@16:             future_.swap(other.future_);
Chris@16:             std::swap(future_obtained,other.future_obtained);
Chris@16:         }
Chris@16: 
Chris@16:         // Result retrieval
Chris@16:         BOOST_THREAD_FUTURE<R> get_future()
Chris@16:         {
Chris@16:             lazy_init();
Chris@16:             if (future_.get()==0)
Chris@16:             {
Chris@16:                 boost::throw_exception(promise_moved());
Chris@16:             }
Chris@16:             if (future_obtained)
Chris@16:             {
Chris@16:                 boost::throw_exception(future_already_retrieved());
Chris@16:             }
Chris@16:             future_obtained=true;
Chris@16:             return BOOST_THREAD_FUTURE<R>(future_);
Chris@16:         }
Chris@16: 
Chris@16:         void set_value(typename detail::future_traits<R>::source_reference_type r)
Chris@16:         {
Chris@16:             lazy_init();
Chris@16:             boost::unique_lock<boost::mutex> lock(future_->mutex);
Chris@16:             if(future_->done)
Chris@16:             {
Chris@16:                 boost::throw_exception(promise_already_satisfied());
Chris@16:             }
Chris@16:             future_->mark_finished_with_result_internal(r, lock);
Chris@16:         }
Chris@16: 
Chris@16: //         void set_value(R && r);
Chris@16:         void set_value(typename detail::future_traits<R>::rvalue_source_type r)
Chris@16:         {
Chris@16:             lazy_init();
Chris@16:             boost::unique_lock<boost::mutex> lock(future_->mutex);
Chris@16:             if(future_->done)
Chris@16:             {
Chris@16:                 boost::throw_exception(promise_already_satisfied());
Chris@16:             }
Chris@16: #if ! defined  BOOST_NO_CXX11_RVALUE_REFERENCES
Chris@16:             future_->mark_finished_with_result_internal(boost::forward<R>(r), lock);
Chris@16: #else
Chris@16:             future_->mark_finished_with_result_internal(static_cast<typename detail::future_traits<R>::rvalue_source_type>(r), lock);
Chris@16: #endif
Chris@16:         }
Chris@16: 
Chris@16:         void set_exception(boost::exception_ptr p)
Chris@16:         {
Chris@16:             lazy_init();
Chris@16:             boost::unique_lock<boost::mutex> lock(future_->mutex);
Chris@16:             if(future_->done)
Chris@16:             {
Chris@16:                 boost::throw_exception(promise_already_satisfied());
Chris@16:             }
Chris@16:             future_->mark_exceptional_finish_internal(p, lock);
Chris@16:         }
Chris@16:         template <typename E>
Chris@16:         void set_exception(E ex)
Chris@16:         {
Chris@16:           set_exception(copy_exception(ex));
Chris@16:         }
Chris@16:         // setting the result with deferred notification
Chris@16:         void set_value_at_thread_exit(const R& r)
Chris@16:         {
Chris@16:           if (future_.get()==0)
Chris@16:           {
Chris@16:               boost::throw_exception(promise_moved());
Chris@16:           }
Chris@16:           future_->set_value_at_thread_exit(r);
Chris@16:         }
Chris@16: 
Chris@16:         void set_value_at_thread_exit(BOOST_THREAD_RV_REF(R) r)
Chris@16:         {
Chris@16:           if (future_.get()==0)
Chris@16:           {
Chris@16:               boost::throw_exception(promise_moved());
Chris@16:           }
Chris@16:           future_->set_value_at_thread_exit(boost::move(r));
Chris@16:         }
Chris@16:         void set_exception_at_thread_exit(exception_ptr e)
Chris@16:         {
Chris@16:           if (future_.get()==0)
Chris@16:           {
Chris@16:               boost::throw_exception(promise_moved());
Chris@16:           }
Chris@16:           future_->set_exception_at_thread_exit(e);
Chris@16:         }
Chris@16:         template <typename E>
Chris@16:         void set_exception_at_thread_exit(E ex)
Chris@16:         {
Chris@16:           set_exception_at_thread_exit(copy_exception(ex));
Chris@16:         }
Chris@16: 
Chris@16:         template<typename F>
Chris@16:         void set_wait_callback(F f)
Chris@16:         {
Chris@16:             lazy_init();
Chris@16:             future_->set_wait_callback(f,this);
Chris@16:         }
Chris@16: 
Chris@16:     };
Chris@16: 
Chris@16:     template <typename R>
Chris@16:     class promise<R&>
Chris@16:     {
Chris@16:         typedef boost::shared_ptr<detail::shared_state<R&> > future_ptr;
Chris@16: 
Chris@16:         future_ptr future_;
Chris@16:         bool future_obtained;
Chris@16: 
Chris@16:         void lazy_init()
Chris@16:         {
Chris@16: #if defined BOOST_THREAD_PROVIDES_PROMISE_LAZY
Chris@16: #include <boost/detail/atomic_undef_macros.hpp>
Chris@16:             if(!atomic_load(&future_))
Chris@16:             {
Chris@16:                 future_ptr blank;
Chris@16:                 atomic_compare_exchange(&future_,&blank,future_ptr(new detail::shared_state<R&>));
Chris@16:             }
Chris@16: #include <boost/detail/atomic_redef_macros.hpp>
Chris@16: #endif
Chris@16:         }
Chris@16: 
Chris@16:     public:
Chris@16:         BOOST_THREAD_MOVABLE_ONLY(promise)
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_CTOR_ALLOCATORS
Chris@16:         template <class Allocator>
Chris@16:         promise(boost::allocator_arg_t, Allocator a)
Chris@16:         {
Chris@16:           typedef typename Allocator::template rebind<detail::shared_state<R&> >::other A2;
Chris@16:           A2 a2(a);
Chris@16:           typedef thread_detail::allocator_destructor<A2> D;
Chris@16: 
Chris@16:           future_ = future_ptr(::new(a2.allocate(1)) detail::shared_state<R&>(), D(a2, 1) );
Chris@16:           future_obtained = false;
Chris@16:         }
Chris@16: #endif
Chris@16:         promise():
Chris@16: #if defined BOOST_THREAD_PROVIDES_PROMISE_LAZY
Chris@16:             future_(),
Chris@16: #else
Chris@16:             future_(new detail::shared_state<R&>()),
Chris@16: #endif
Chris@16:             future_obtained(false)
Chris@16:         {}
Chris@16: 
Chris@16:         ~promise()
Chris@16:         {
Chris@16:             if(future_)
Chris@16:             {
Chris@16:                 boost::unique_lock<boost::mutex> lock(future_->mutex);
Chris@16: 
Chris@16:                 if(!future_->done && !future_->is_constructed)
Chris@16:                 {
Chris@16:                     future_->mark_exceptional_finish_internal(boost::copy_exception(broken_promise()), lock);
Chris@16:                 }
Chris@16:             }
Chris@16:         }
Chris@16: 
Chris@16:         // Assignment
Chris@16:         promise(BOOST_THREAD_RV_REF(promise) rhs) BOOST_NOEXCEPT :
Chris@16:             future_(BOOST_THREAD_RV(rhs).future_),future_obtained(BOOST_THREAD_RV(rhs).future_obtained)
Chris@16:         {
Chris@16:             BOOST_THREAD_RV(rhs).future_.reset();
Chris@16:             BOOST_THREAD_RV(rhs).future_obtained=false;
Chris@16:         }
Chris@16:         promise & operator=(BOOST_THREAD_RV_REF(promise) rhs) BOOST_NOEXCEPT
Chris@16:         {
Chris@16:             future_=BOOST_THREAD_RV(rhs).future_;
Chris@16:             future_obtained=BOOST_THREAD_RV(rhs).future_obtained;
Chris@16:             BOOST_THREAD_RV(rhs).future_.reset();
Chris@16:             BOOST_THREAD_RV(rhs).future_obtained=false;
Chris@16:             return *this;
Chris@16:         }
Chris@16: 
Chris@16:         void swap(promise& other)
Chris@16:         {
Chris@16:             future_.swap(other.future_);
Chris@16:             std::swap(future_obtained,other.future_obtained);
Chris@16:         }
Chris@16: 
Chris@16:         // Result retrieval
Chris@16:         BOOST_THREAD_FUTURE<R&> get_future()
Chris@16:         {
Chris@16:             lazy_init();
Chris@16:             if (future_.get()==0)
Chris@16:             {
Chris@16:                 boost::throw_exception(promise_moved());
Chris@16:             }
Chris@16:             if (future_obtained)
Chris@16:             {
Chris@16:                 boost::throw_exception(future_already_retrieved());
Chris@16:             }
Chris@16:             future_obtained=true;
Chris@16:             return BOOST_THREAD_FUTURE<R&>(future_);
Chris@16:         }
Chris@16: 
Chris@16:         void set_value(R& r)
Chris@16:         {
Chris@16:             lazy_init();
Chris@16:             boost::unique_lock<boost::mutex> lock(future_->mutex);
Chris@16:             if(future_->done)
Chris@16:             {
Chris@16:                 boost::throw_exception(promise_already_satisfied());
Chris@16:             }
Chris@16:             future_->mark_finished_with_result_internal(r, lock);
Chris@16:         }
Chris@16: 
Chris@16:         void set_exception(boost::exception_ptr p)
Chris@16:         {
Chris@16:             lazy_init();
Chris@16:             boost::unique_lock<boost::mutex> lock(future_->mutex);
Chris@16:             if(future_->done)
Chris@16:             {
Chris@16:                 boost::throw_exception(promise_already_satisfied());
Chris@16:             }
Chris@16:             future_->mark_exceptional_finish_internal(p, lock);
Chris@16:         }
Chris@16:         template <typename E>
Chris@16:         void set_exception(E ex)
Chris@16:         {
Chris@16:           set_exception(copy_exception(ex));
Chris@16:         }
Chris@16: 
Chris@16:         // setting the result with deferred notification
Chris@16:         void set_value_at_thread_exit(R& r)
Chris@16:         {
Chris@16:           if (future_.get()==0)
Chris@16:           {
Chris@16:               boost::throw_exception(promise_moved());
Chris@16:           }
Chris@16:           future_->set_value_at_thread_exit(r);
Chris@16:         }
Chris@16: 
Chris@16:         void set_exception_at_thread_exit(exception_ptr e)
Chris@16:         {
Chris@16:           if (future_.get()==0)
Chris@16:           {
Chris@16:               boost::throw_exception(promise_moved());
Chris@16:           }
Chris@16:           future_->set_exception_at_thread_exit(e);
Chris@16:         }
Chris@16:         template <typename E>
Chris@16:         void set_exception_at_thread_exit(E ex)
Chris@16:         {
Chris@16:           set_exception_at_thread_exit(copy_exception(ex));
Chris@16:         }
Chris@16: 
Chris@16:         template<typename F>
Chris@16:         void set_wait_callback(F f)
Chris@16:         {
Chris@16:             lazy_init();
Chris@16:             future_->set_wait_callback(f,this);
Chris@16:         }
Chris@16: 
Chris@16:     };
Chris@16:     template <>
Chris@16:     class promise<void>
Chris@16:     {
Chris@16:         typedef boost::shared_ptr<detail::shared_state<void> > future_ptr;
Chris@16: 
Chris@16:         future_ptr future_;
Chris@16:         bool future_obtained;
Chris@16: 
Chris@16:         void lazy_init()
Chris@16:         {
Chris@16: #if defined BOOST_THREAD_PROVIDES_PROMISE_LAZY
Chris@16:             if(!atomic_load(&future_))
Chris@16:             {
Chris@16:                 future_ptr blank;
Chris@16:                 atomic_compare_exchange(&future_,&blank,future_ptr(new detail::shared_state<void>));
Chris@16:             }
Chris@16: #endif
Chris@16:         }
Chris@16:     public:
Chris@16:         BOOST_THREAD_MOVABLE_ONLY(promise)
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_CTOR_ALLOCATORS
Chris@16:         template <class Allocator>
Chris@16:         promise(boost::allocator_arg_t, Allocator a)
Chris@16:         {
Chris@16:           typedef typename Allocator::template rebind<detail::shared_state<void> >::other A2;
Chris@16:           A2 a2(a);
Chris@16:           typedef thread_detail::allocator_destructor<A2> D;
Chris@16: 
Chris@16:           future_ = future_ptr(::new(a2.allocate(1)) detail::shared_state<void>(), D(a2, 1) );
Chris@16:           future_obtained = false;
Chris@16:         }
Chris@16: #endif
Chris@16:         promise():
Chris@16: #if defined BOOST_THREAD_PROVIDES_PROMISE_LAZY
Chris@16:             future_(),
Chris@16: #else
Chris@16:             future_(new detail::shared_state<void>),
Chris@16: #endif
Chris@16:             future_obtained(false)
Chris@16:         {}
Chris@16: 
Chris@16:         ~promise()
Chris@16:         {
Chris@16:             if(future_)
Chris@16:             {
Chris@16:                 boost::unique_lock<boost::mutex> lock(future_->mutex);
Chris@16: 
Chris@16:                 if(!future_->done && !future_->is_constructed)
Chris@16:                 {
Chris@16:                     future_->mark_exceptional_finish_internal(boost::copy_exception(broken_promise()), lock);
Chris@16:                 }
Chris@16:             }
Chris@16:         }
Chris@16: 
Chris@16:         // Assignment
Chris@16:         promise(BOOST_THREAD_RV_REF(promise) rhs) BOOST_NOEXCEPT :
Chris@16:             future_(BOOST_THREAD_RV(rhs).future_),future_obtained(BOOST_THREAD_RV(rhs).future_obtained)
Chris@16:         {
Chris@16:           // we need to release the future as shared_ptr doesn't implements move semantics
Chris@16:             BOOST_THREAD_RV(rhs).future_.reset();
Chris@16:             BOOST_THREAD_RV(rhs).future_obtained=false;
Chris@16:         }
Chris@16: 
Chris@16:         promise & operator=(BOOST_THREAD_RV_REF(promise) rhs) BOOST_NOEXCEPT
Chris@16:         {
Chris@16:             future_=BOOST_THREAD_RV(rhs).future_;
Chris@16:             future_obtained=BOOST_THREAD_RV(rhs).future_obtained;
Chris@16:             BOOST_THREAD_RV(rhs).future_.reset();
Chris@16:             BOOST_THREAD_RV(rhs).future_obtained=false;
Chris@16:             return *this;
Chris@16:         }
Chris@16: 
Chris@16:         void swap(promise& other)
Chris@16:         {
Chris@16:             future_.swap(other.future_);
Chris@16:             std::swap(future_obtained,other.future_obtained);
Chris@16:         }
Chris@16: 
Chris@16:         // Result retrieval
Chris@16:         BOOST_THREAD_FUTURE<void> get_future()
Chris@16:         {
Chris@16:             lazy_init();
Chris@16: 
Chris@16:             if (future_.get()==0)
Chris@16:             {
Chris@16:                 boost::throw_exception(promise_moved());
Chris@16:             }
Chris@16:             if(future_obtained)
Chris@16:             {
Chris@16:                 boost::throw_exception(future_already_retrieved());
Chris@16:             }
Chris@16:             future_obtained=true;
Chris@16:             return BOOST_THREAD_FUTURE<void>(future_);
Chris@16:         }
Chris@16: 
Chris@16:         void set_value()
Chris@16:         {
Chris@16:             lazy_init();
Chris@16:             boost::unique_lock<boost::mutex> lock(future_->mutex);
Chris@16:             if(future_->done)
Chris@16:             {
Chris@16:                 boost::throw_exception(promise_already_satisfied());
Chris@16:             }
Chris@16:             future_->mark_finished_with_result_internal(lock);
Chris@16:         }
Chris@16: 
Chris@16:         void set_exception(boost::exception_ptr p)
Chris@16:         {
Chris@16:             lazy_init();
Chris@16:             boost::unique_lock<boost::mutex> lock(future_->mutex);
Chris@16:             if(future_->done)
Chris@16:             {
Chris@16:                 boost::throw_exception(promise_already_satisfied());
Chris@16:             }
Chris@16:             future_->mark_exceptional_finish_internal(p,lock);
Chris@16:         }
Chris@16:         template <typename E>
Chris@16:         void set_exception(E ex)
Chris@16:         {
Chris@16:           set_exception(copy_exception(ex));
Chris@16:         }
Chris@16: 
Chris@16:         // setting the result with deferred notification
Chris@16:         void set_value_at_thread_exit()
Chris@16:         {
Chris@16:           if (future_.get()==0)
Chris@16:           {
Chris@16:               boost::throw_exception(promise_moved());
Chris@16:           }
Chris@16:           future_->set_value_at_thread_exit();
Chris@16:         }
Chris@16: 
Chris@16:         void set_exception_at_thread_exit(exception_ptr e)
Chris@16:         {
Chris@16:           if (future_.get()==0)
Chris@16:           {
Chris@16:               boost::throw_exception(promise_moved());
Chris@16:           }
Chris@16:           future_->set_exception_at_thread_exit(e);
Chris@16:         }
Chris@16:         template <typename E>
Chris@16:         void set_exception_at_thread_exit(E ex)
Chris@16:         {
Chris@16:           set_exception_at_thread_exit(copy_exception(ex));
Chris@16:         }
Chris@16: 
Chris@16:         template<typename F>
Chris@16:         void set_wait_callback(F f)
Chris@16:         {
Chris@16:             lazy_init();
Chris@16:             future_->set_wait_callback(f,this);
Chris@16:         }
Chris@16: 
Chris@16:     };
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_CTOR_ALLOCATORS
Chris@16:     namespace container
Chris@16:     {
Chris@16:       template <class R, class Alloc>
Chris@16:       struct uses_allocator<promise<R> , Alloc> : true_type
Chris@16:       {
Chris@16:       };
Chris@16:     }
Chris@16: #endif
Chris@16: 
Chris@16:     BOOST_THREAD_DCL_MOVABLE_BEG(T) promise<T> BOOST_THREAD_DCL_MOVABLE_END
Chris@16: 
Chris@16:     namespace detail
Chris@16:     {
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16:       template<typename R>
Chris@16:       struct task_base_shared_state;
Chris@16: #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:       template<typename R, typename ...ArgTypes>
Chris@16:       struct task_base_shared_state<R(ArgTypes...)>:
Chris@16: #else
Chris@16:       template<typename R>
Chris@16:       struct task_base_shared_state<R()>:
Chris@16: #endif
Chris@16: #else
Chris@16:       template<typename R>
Chris@16:       struct task_base_shared_state:
Chris@16: #endif
Chris@16:             detail::shared_state<R>
Chris@16:         {
Chris@16:             bool started;
Chris@16: 
Chris@16:             task_base_shared_state():
Chris@16:                 started(false)
Chris@16:             {}
Chris@16: 
Chris@16:             void reset()
Chris@16:             {
Chris@16:               started=false;
Chris@16:             }
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:             virtual void do_run(BOOST_THREAD_RV_REF(ArgTypes) ... args)=0;
Chris@16:             void run(BOOST_THREAD_RV_REF(ArgTypes) ... args)
Chris@16: #else
Chris@16:             virtual void do_run()=0;
Chris@16:             void run()
Chris@16: #endif
Chris@16:             {
Chris@16:                 {
Chris@16:                     boost::lock_guard<boost::mutex> lk(this->mutex);
Chris@16:                     if(started)
Chris@16:                     {
Chris@16:                         boost::throw_exception(task_already_started());
Chris@16:                     }
Chris@16:                     started=true;
Chris@16:                 }
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:                 do_run(boost::forward<ArgTypes>(args)...);
Chris@16: #else
Chris@16:                 do_run();
Chris@16: #endif
Chris@16:             }
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:             virtual void do_apply(BOOST_THREAD_RV_REF(ArgTypes) ... args)=0;
Chris@16:             void apply(BOOST_THREAD_RV_REF(ArgTypes) ... args)
Chris@16: #else
Chris@16:             virtual void do_apply()=0;
Chris@16:             void apply()
Chris@16: #endif
Chris@16:             {
Chris@16:                 {
Chris@16:                     boost::lock_guard<boost::mutex> lk(this->mutex);
Chris@16:                     if(started)
Chris@16:                     {
Chris@16:                         boost::throw_exception(task_already_started());
Chris@16:                     }
Chris@16:                     started=true;
Chris@16:                 }
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:                 do_apply(boost::forward<ArgTypes>(args)...);
Chris@16: #else
Chris@16:                 do_apply();
Chris@16: #endif
Chris@16:             }
Chris@16: 
Chris@16:             void owner_destroyed()
Chris@16:             {
Chris@16:                 boost::unique_lock<boost::mutex> lk(this->mutex);
Chris@16:                 if(!started)
Chris@16:                 {
Chris@16:                     started=true;
Chris@16:                     this->mark_exceptional_finish_internal(boost::copy_exception(boost::broken_promise()), lk);
Chris@16:                 }
Chris@16:             }
Chris@16: 
Chris@16:         };
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16:         template<typename F, typename R>
Chris@16:         struct task_shared_state;
Chris@16: #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:         template<typename F, typename R, typename ...ArgTypes>
Chris@16:         struct task_shared_state<F, R(ArgTypes...)>:
Chris@16:           task_base_shared_state<R(ArgTypes...)>
Chris@16: #else
Chris@16:         template<typename F, typename R>
Chris@16:         struct task_shared_state<F, R()>:
Chris@16:           task_base_shared_state<R()>
Chris@16: #endif
Chris@16: #else
Chris@16:         template<typename F, typename R>
Chris@16:         struct task_shared_state:
Chris@16:             task_base_shared_state<R>
Chris@16: #endif
Chris@16:         {
Chris@16:         private:
Chris@16:           task_shared_state(task_shared_state&);
Chris@16:         public:
Chris@16:             F f;
Chris@16:             task_shared_state(F const& f_):
Chris@16:                 f(f_)
Chris@16:             {}
Chris@16:             task_shared_state(BOOST_THREAD_RV_REF(F) f_):
Chris@16:               f(boost::move(f_))
Chris@16:             {}
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:             void do_apply(BOOST_THREAD_RV_REF(ArgTypes) ... args)
Chris@16:             {
Chris@16:                 try
Chris@16:                 {
Chris@16:                     this->set_value_at_thread_exit(f(boost::forward<ArgTypes>(args)...));
Chris@16:                 }
Chris@16: #else
Chris@16:             void do_apply()
Chris@16:             {
Chris@16:                 try
Chris@16:                 {
Chris@16:                     this->set_value_at_thread_exit(f());
Chris@16:                 }
Chris@16: #endif
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                 catch(thread_interrupted& )
Chris@16:                 {
Chris@16:                     this->set_interrupted_at_thread_exit();
Chris@16:                 }
Chris@16: #endif
Chris@16:                 catch(...)
Chris@16:                 {
Chris@16:                     this->set_exception_at_thread_exit(current_exception());
Chris@16:                 }
Chris@16:             }
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:             void do_run(BOOST_THREAD_RV_REF(ArgTypes) ... args)
Chris@16:             {
Chris@16:                 try
Chris@16:                 {
Chris@16:                     this->mark_finished_with_result(f(boost::forward<ArgTypes>(args)...));
Chris@16:                 }
Chris@16: #else
Chris@16:             void do_run()
Chris@16:             {
Chris@16:                 try
Chris@16:                 {
Chris@16: #if ! defined  BOOST_NO_CXX11_RVALUE_REFERENCES
Chris@16:                   R res((f()));
Chris@16:                   this->mark_finished_with_result(boost::move(res));
Chris@16: #else
Chris@16:                   this->mark_finished_with_result(f());
Chris@16: #endif
Chris@16:                   }
Chris@16: #endif
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                 catch(thread_interrupted& )
Chris@16:                 {
Chris@16:                     this->mark_interrupted_finish();
Chris@16:                 }
Chris@16: #endif
Chris@16:                 catch(...)
Chris@16:                 {
Chris@16:                     this->mark_exceptional_finish();
Chris@16:                 }
Chris@16:             }
Chris@16:         };
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16: #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:         template<typename F, typename R, typename ...ArgTypes>
Chris@16:         struct task_shared_state<F, R&(ArgTypes...)>:
Chris@16:           task_base_shared_state<R&(ArgTypes...)>
Chris@16: #else
Chris@16:         template<typename F, typename R>
Chris@16:         struct task_shared_state<F, R&()>:
Chris@16:           task_base_shared_state<R&()>
Chris@16: #endif
Chris@16: #else
Chris@16:         template<typename F, typename R>
Chris@16:         struct task_shared_state<F,R&>:
Chris@16:             task_base_shared_state<R&>
Chris@16: #endif
Chris@16:         {
Chris@16:         private:
Chris@16:           task_shared_state(task_shared_state&);
Chris@16:         public:
Chris@16:             F f;
Chris@16:             task_shared_state(F const& f_):
Chris@16:                 f(f_)
Chris@16:             {}
Chris@16:             task_shared_state(BOOST_THREAD_RV_REF(F) f_):
Chris@16:                 f(boost::move(f_))
Chris@16:             {}
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:             void do_apply(BOOST_THREAD_RV_REF(ArgTypes) ... args)
Chris@16:             {
Chris@16:                 try
Chris@16:                 {
Chris@16:                     this->set_value_at_thread_exit(f(boost::forward<ArgTypes>(args)...));
Chris@16:                 }
Chris@16: #else
Chris@16:             void do_apply()
Chris@16:             {
Chris@16:                 try
Chris@16:                 {
Chris@16:                     this->set_value_at_thread_exit(f());
Chris@16:                 }
Chris@16: #endif
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                 catch(thread_interrupted& )
Chris@16:                 {
Chris@16:                     this->set_interrupted_at_thread_exit();
Chris@16:                 }
Chris@16: #endif
Chris@16:                 catch(...)
Chris@16:                 {
Chris@16:                     this->set_exception_at_thread_exit(current_exception());
Chris@16:                 }
Chris@16:             }
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:             void do_run(BOOST_THREAD_RV_REF(ArgTypes) ... args)
Chris@16:             {
Chris@16:                 try
Chris@16:                 {
Chris@16:                     this->mark_finished_with_result(f(boost::forward<ArgTypes>(args)...));
Chris@16:                 }
Chris@16: #else
Chris@16:             void do_run()
Chris@16:             {
Chris@16:                 try
Chris@16:                 {
Chris@16:                   R& res((f()));
Chris@16:                   this->mark_finished_with_result(res);
Chris@16:                 }
Chris@16: #endif
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                 catch(thread_interrupted& )
Chris@16:                 {
Chris@16:                     this->mark_interrupted_finish();
Chris@16:                 }
Chris@16: #endif
Chris@16:                 catch(...)
Chris@16:                 {
Chris@16:                     this->mark_exceptional_finish();
Chris@16:                 }
Chris@16:             }
Chris@16:         };
Chris@16: 
Chris@16: #if defined(BOOST_THREAD_RVALUE_REFERENCES_DONT_MATCH_FUNTION_PTR)
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16: #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:         template<typename R, typename ...ArgTypes>
Chris@16:         struct task_shared_state<R (*)(ArgTypes...), R(ArgTypes...)>:
Chris@16:           task_base_shared_state<R(ArgTypes...)>
Chris@16: #else
Chris@16:         template<typename R>
Chris@16:         struct task_shared_state<R (*)(), R()>:
Chris@16:           task_base_shared_state<R()>
Chris@16: #endif
Chris@16: #else
Chris@16:         template<typename R>
Chris@16:         struct task_shared_state<R (*)(), R> :
Chris@16:            task_base_shared_state<R>
Chris@16: #endif
Chris@16:             {
Chris@16:             private:
Chris@16:               task_shared_state(task_shared_state&);
Chris@16:             public:
Chris@16:                 R (*f)();
Chris@16:                 task_shared_state(R (*f_)()):
Chris@16:                     f(f_)
Chris@16:                 {}
Chris@16: 
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:                 void do_apply(BOOST_THREAD_RV_REF(ArgTypes) ... args)
Chris@16:                 {
Chris@16:                     try
Chris@16:                     {
Chris@16:                         this->set_value_at_thread_exit(f(boost::forward<ArgTypes>(args)...));
Chris@16:                     }
Chris@16: #else
Chris@16:                 void do_apply()
Chris@16:                 {
Chris@16:                     try
Chris@16:                     {
Chris@16:                         R r((f()));
Chris@16:                         this->set_value_at_thread_exit(boost::move(r));
Chris@16:                     }
Chris@16: #endif
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                     catch(thread_interrupted& )
Chris@16:                     {
Chris@16:                         this->set_interrupted_at_thread_exit();
Chris@16:                     }
Chris@16: #endif
Chris@16:                     catch(...)
Chris@16:                     {
Chris@16:                         this->set_exception_at_thread_exit(current_exception());
Chris@16:                     }
Chris@16:                 }
Chris@16: 
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:                 void do_run(BOOST_THREAD_RV_REF(ArgTypes) ... args)
Chris@16:                 {
Chris@16:                     try
Chris@16:                     {
Chris@16:                         this->mark_finished_with_result(f(boost::forward<ArgTypes>(args)...));
Chris@16:                     }
Chris@16: #else
Chris@16:                 void do_run()
Chris@16:                 {
Chris@16:                     try
Chris@16:                     {
Chris@16:                         R res((f()));
Chris@16:                         this->mark_finished_with_result(boost::move(res));
Chris@16:                     }
Chris@16: #endif
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                     catch(thread_interrupted& )
Chris@16:                     {
Chris@16:                         this->mark_interrupted_finish();
Chris@16:                     }
Chris@16: #endif
Chris@16:                     catch(...)
Chris@16:                     {
Chris@16:                         this->mark_exceptional_finish();
Chris@16:                     }
Chris@16:                 }
Chris@16:             };
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16: #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:         template<typename R, typename ...ArgTypes>
Chris@16:         struct task_shared_state<R& (*)(ArgTypes...), R&(ArgTypes...)>:
Chris@16:           task_base_shared_state<R&(ArgTypes...)>
Chris@16: #else
Chris@16:         template<typename R>
Chris@16:         struct task_shared_state<R& (*)(), R&()>:
Chris@16:           task_base_shared_state<R&()>
Chris@16: #endif
Chris@16: #else
Chris@16:         template<typename R>
Chris@16:         struct task_shared_state<R& (*)(), R&> :
Chris@16:            task_base_shared_state<R&>
Chris@16: #endif
Chris@16:             {
Chris@16:             private:
Chris@16:               task_shared_state(task_shared_state&);
Chris@16:             public:
Chris@16:                 R& (*f)();
Chris@16:                 task_shared_state(R& (*f_)()):
Chris@16:                     f(f_)
Chris@16:                 {}
Chris@16: 
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:                 void do_apply(BOOST_THREAD_RV_REF(ArgTypes) ... args)
Chris@16:                 {
Chris@16:                     try
Chris@16:                     {
Chris@16:                         this->set_value_at_thread_exit(f(boost::forward<ArgTypes>(args)...));
Chris@16:                     }
Chris@16: #else
Chris@16:                 void do_apply()
Chris@16:                 {
Chris@16:                     try
Chris@16:                     {
Chris@16:                       this->set_value_at_thread_exit(f());
Chris@16:                     }
Chris@16: #endif
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                     catch(thread_interrupted& )
Chris@16:                     {
Chris@16:                         this->set_interrupted_at_thread_exit();
Chris@16:                     }
Chris@16: #endif
Chris@16:                     catch(...)
Chris@16:                     {
Chris@16:                         this->set_exception_at_thread_exit(current_exception());
Chris@16:                     }
Chris@16:                 }
Chris@16: 
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:                 void do_run(BOOST_THREAD_RV_REF(ArgTypes) ... args)
Chris@16:                 {
Chris@16:                     try
Chris@16:                     {
Chris@16:                         this->mark_finished_with_result(f(boost::forward<ArgTypes>(args)...));
Chris@16:                     }
Chris@16: #else
Chris@16:                 void do_run()
Chris@16:                 {
Chris@16:                     try
Chris@16:                     {
Chris@16:                         this->mark_finished_with_result(f());
Chris@16:                     }
Chris@16: #endif
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                     catch(thread_interrupted& )
Chris@16:                     {
Chris@16:                         this->mark_interrupted_finish();
Chris@16:                     }
Chris@16: #endif
Chris@16:                     catch(...)
Chris@16:                     {
Chris@16:                         this->mark_exceptional_finish();
Chris@16:                     }
Chris@16:                 }
Chris@16:             };
Chris@16: #endif
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16: #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:         template<typename F, typename ...ArgTypes>
Chris@16:         struct task_shared_state<F, void(ArgTypes...)>:
Chris@16:           task_base_shared_state<void(ArgTypes...)>
Chris@16: #else
Chris@16:         template<typename F>
Chris@16:         struct task_shared_state<F, void()>:
Chris@16:           task_base_shared_state<void()>
Chris@16: #endif
Chris@16: #else
Chris@16:         template<typename F>
Chris@16:         struct task_shared_state<F,void>:
Chris@16:           task_base_shared_state<void>
Chris@16: #endif
Chris@16:         {
Chris@16:         private:
Chris@16:           task_shared_state(task_shared_state&);
Chris@16:         public:
Chris@16:             F f;
Chris@16:             task_shared_state(F const& f_):
Chris@16:                 f(f_)
Chris@16:             {}
Chris@16:             task_shared_state(BOOST_THREAD_RV_REF(F) f_):
Chris@16:                 f(boost::move(f_))
Chris@16:             {}
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:             void do_apply(BOOST_THREAD_RV_REF(ArgTypes) ... args)
Chris@16:             {
Chris@16:               try
Chris@16:               {
Chris@16:                 f(boost::forward<ArgTypes>(args)...);
Chris@16: #else
Chris@16:             void do_apply()
Chris@16:             {
Chris@16:                 try
Chris@16:                 {
Chris@16:                     f();
Chris@16: #endif
Chris@16:                   this->set_value_at_thread_exit();
Chris@16:                 }
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                 catch(thread_interrupted& )
Chris@16:                 {
Chris@16:                     this->set_interrupted_at_thread_exit();
Chris@16:                 }
Chris@16: #endif
Chris@16:                 catch(...)
Chris@16:                 {
Chris@16:                     this->set_exception_at_thread_exit(current_exception());
Chris@16:                 }
Chris@16:             }
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:             void do_run(BOOST_THREAD_RV_REF(ArgTypes) ... args)
Chris@16:             {
Chris@16:                 try
Chris@16:                 {
Chris@16:                     f(boost::forward<ArgTypes>(args)...);
Chris@16: #else
Chris@16:             void do_run()
Chris@16:             {
Chris@16:                 try
Chris@16:                 {
Chris@16:                     f();
Chris@16: #endif
Chris@16:                     this->mark_finished_with_result();
Chris@16:                 }
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                 catch(thread_interrupted& )
Chris@16:                 {
Chris@16:                     this->mark_interrupted_finish();
Chris@16:                 }
Chris@16: #endif
Chris@16:                 catch(...)
Chris@16:                 {
Chris@16:                     this->mark_exceptional_finish();
Chris@16:                 }
Chris@16:             }
Chris@16:         };
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16: #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:         template<typename ...ArgTypes>
Chris@16:         struct task_shared_state<void (*)(ArgTypes...), void(ArgTypes...)>:
Chris@16:         task_base_shared_state<void(ArgTypes...)>
Chris@16: #else
Chris@16:         template<>
Chris@16:         struct task_shared_state<void (*)(), void()>:
Chris@16:         task_base_shared_state<void()>
Chris@16: #endif
Chris@16: #else
Chris@16:         template<>
Chris@16:         struct task_shared_state<void (*)(),void>:
Chris@16:           task_base_shared_state<void>
Chris@16: #endif
Chris@16:         {
Chris@16:         private:
Chris@16:           task_shared_state(task_shared_state&);
Chris@16:         public:
Chris@16:             void (*f)();
Chris@16:             task_shared_state(void (*f_)()):
Chris@16:                 f(f_)
Chris@16:             {}
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:             void do_apply(BOOST_THREAD_RV_REF(ArgTypes) ... args)
Chris@16:             {
Chris@16:                 try
Chris@16:                 {
Chris@16:                     f(boost::forward<ArgTypes>(args)...);
Chris@16: #else
Chris@16:             void do_apply()
Chris@16:             {
Chris@16:                 try
Chris@16:                 {
Chris@16:                     f();
Chris@16: #endif
Chris@16:                     this->set_value_at_thread_exit();
Chris@16:                 }
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                 catch(thread_interrupted& )
Chris@16:                 {
Chris@16:                     this->set_interrupted_at_thread_exit();
Chris@16:                 }
Chris@16: #endif
Chris@16:                 catch(...)
Chris@16:                 {
Chris@16:                     this->set_exception_at_thread_exit(current_exception());
Chris@16:                 }
Chris@16:             }
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:             void do_run(BOOST_THREAD_RV_REF(ArgTypes) ... args)
Chris@16:             {
Chris@16:                 try
Chris@16:                 {
Chris@16:                     f(boost::forward<ArgTypes>(args)...);
Chris@16: #else
Chris@16:             void do_run()
Chris@16:             {
Chris@16:                 try
Chris@16:                 {
Chris@16:                   f();
Chris@16: #endif
Chris@16:                   this->mark_finished_with_result();
Chris@16:                 }
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:                 catch(thread_interrupted& )
Chris@16:                 {
Chris@16:                     this->mark_interrupted_finish();
Chris@16:                 }
Chris@16: #endif
Chris@16:                 catch(...)
Chris@16:                 {
Chris@16:                     this->mark_exceptional_finish();
Chris@16:                 }
Chris@16:             }
Chris@16:         };
Chris@16:     }
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16:   #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:     template<typename R, typename ...ArgTypes>
Chris@16:     class packaged_task<R(ArgTypes...)>
Chris@16:     {
Chris@16:       typedef boost::shared_ptr<detail::task_base_shared_state<R(ArgTypes...)> > task_ptr;
Chris@16:       boost::shared_ptr<detail::task_base_shared_state<R(ArgTypes...)> > task;
Chris@16:   #else
Chris@16:     template<typename R>
Chris@16:     class packaged_task<R()>
Chris@16:     {
Chris@16:       typedef boost::shared_ptr<detail::task_base_shared_state<R()> > task_ptr;
Chris@16:       boost::shared_ptr<detail::task_base_shared_state<R()> > task;
Chris@16:   #endif
Chris@16: #else
Chris@16:     template<typename R>
Chris@16:     class packaged_task
Chris@16:     {
Chris@16:       typedef boost::shared_ptr<detail::task_base_shared_state<R> > task_ptr;
Chris@16:       boost::shared_ptr<detail::task_base_shared_state<R> > task;
Chris@16: #endif
Chris@16:         bool future_obtained;
Chris@16:         struct dummy;
Chris@16: 
Chris@16:     public:
Chris@16:         typedef R result_type;
Chris@16:         BOOST_THREAD_MOVABLE_ONLY(packaged_task)
Chris@16: 
Chris@16:         packaged_task():
Chris@16:             future_obtained(false)
Chris@16:         {}
Chris@16: 
Chris@16:         // construction and destruction
Chris@16: #if defined(BOOST_THREAD_RVALUE_REFERENCES_DONT_MATCH_FUNTION_PTR)
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16:   #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:         explicit packaged_task(R(*f)(), BOOST_THREAD_FWD_REF(ArgTypes)... args)
Chris@16:         {
Chris@16:             typedef R(*FR)(BOOST_THREAD_FWD_REF(ArgTypes)...);
Chris@16:             typedef detail::task_shared_state<FR,R(ArgTypes...)> task_shared_state_type;
Chris@16:             task= task_ptr(new task_shared_state_type(f, boost::forward<ArgTypes>(args)...));
Chris@16:             future_obtained=false;
Chris@16:         }
Chris@16:   #else
Chris@16:         explicit packaged_task(R(*f)())
Chris@16:         {
Chris@16:             typedef R(*FR)();
Chris@16:             typedef detail::task_shared_state<FR,R()> task_shared_state_type;
Chris@16:             task= task_ptr(new task_shared_state_type(f));
Chris@16:             future_obtained=false;
Chris@16:         }
Chris@16:   #endif
Chris@16: #else
Chris@16:         explicit packaged_task(R(*f)())
Chris@16:         {
Chris@16:               typedef R(*FR)();
Chris@16:             typedef detail::task_shared_state<FR,R> task_shared_state_type;
Chris@16:             task= task_ptr(new task_shared_state_type(f));
Chris@16:             future_obtained=false;
Chris@16:         }
Chris@16: #endif
Chris@16: #endif
Chris@16: #ifndef BOOST_NO_CXX11_RVALUE_REFERENCES
Chris@16:         template <class F>
Chris@16:         explicit packaged_task(BOOST_THREAD_FWD_REF(F) f
Chris@16:             , typename boost::disable_if<is_same<typename decay<F>::type, packaged_task>, dummy* >::type=0
Chris@16:             )
Chris@16:         {
Chris@16:           typedef typename remove_cv<typename remove_reference<F>::type>::type FR;
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16:   #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:             typedef detail::task_shared_state<FR,R(ArgTypes...)> task_shared_state_type;
Chris@16:   #else
Chris@16:             typedef detail::task_shared_state<FR,R()> task_shared_state_type;
Chris@16:   #endif
Chris@16: #else
Chris@16:             typedef detail::task_shared_state<FR,R> task_shared_state_type;
Chris@16: #endif
Chris@16:             task = task_ptr(new task_shared_state_type(boost::forward<F>(f)));
Chris@16:             future_obtained = false;
Chris@16: 
Chris@16:         }
Chris@16: 
Chris@16: #else
Chris@16:         template <class F>
Chris@16:         explicit packaged_task(F const& f
Chris@16:             , typename boost::disable_if<is_same<typename decay<F>::type, packaged_task>, dummy* >::type=0
Chris@16:             )
Chris@16:         {
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16:   #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:             typedef detail::task_shared_state<F,R(ArgTypes...)> task_shared_state_type;
Chris@16:   #else
Chris@16:             typedef detail::task_shared_state<F,R()> task_shared_state_type;
Chris@16:   #endif
Chris@16: #else
Chris@16:             typedef detail::task_shared_state<F,R> task_shared_state_type;
Chris@16: #endif
Chris@16:             task = task_ptr(new task_shared_state_type(f));
Chris@16:             future_obtained=false;
Chris@16:         }
Chris@16:         template <class F>
Chris@16:         explicit packaged_task(BOOST_THREAD_RV_REF(F) f)
Chris@16:         {
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16: #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:             typedef detail::task_shared_state<F,R(ArgTypes...)> task_shared_state_type;
Chris@16:             task = task_ptr(new task_shared_state_type(boost::forward<F>(f)));
Chris@16: #else
Chris@16:             typedef detail::task_shared_state<F,R()> task_shared_state_type;
Chris@16:             task = task_ptr(new task_shared_state_type(boost::move(f))); // TODO forward
Chris@16: #endif
Chris@16: #else
Chris@16:             typedef detail::task_shared_state<F,R> task_shared_state_type;
Chris@16:             task = task_ptr(new task_shared_state_type(boost::forward<F>(f)));
Chris@16: #endif
Chris@16:             future_obtained=false;
Chris@16: 
Chris@16:         }
Chris@16: #endif
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_CTOR_ALLOCATORS
Chris@16: #if defined(BOOST_THREAD_RVALUE_REFERENCES_DONT_MATCH_FUNTION_PTR)
Chris@16:         template <class Allocator>
Chris@16:         packaged_task(boost::allocator_arg_t, Allocator a, R(*f)())
Chris@16:         {
Chris@16:           typedef R(*FR)();
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16:   #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:           typedef detail::task_shared_state<FR,R(ArgTypes...)> task_shared_state_type;
Chris@16:   #else
Chris@16:           typedef detail::task_shared_state<FR,R()> task_shared_state_type;
Chris@16:   #endif
Chris@16: #else
Chris@16:           typedef detail::task_shared_state<FR,R> task_shared_state_type;
Chris@16: #endif
Chris@16:           typedef typename Allocator::template rebind<task_shared_state_type>::other A2;
Chris@16:           A2 a2(a);
Chris@16:           typedef thread_detail::allocator_destructor<A2> D;
Chris@16: 
Chris@16:           task = task_ptr(::new(a2.allocate(1)) task_shared_state_type(f), D(a2, 1) );
Chris@16:           future_obtained = false;
Chris@16:         }
Chris@16: #endif // BOOST_THREAD_RVALUE_REFERENCES_DONT_MATCH_FUNTION_PTR
Chris@16: 
Chris@16: #if ! defined BOOST_NO_CXX11_RVALUE_REFERENCES
Chris@16:         template <class F, class Allocator>
Chris@16:         packaged_task(boost::allocator_arg_t, Allocator a, BOOST_THREAD_FWD_REF(F) f)
Chris@16:         {
Chris@16:           typedef typename remove_cv<typename remove_reference<F>::type>::type FR;
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16:   #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:           typedef detail::task_shared_state<FR,R(ArgTypes...)> task_shared_state_type;
Chris@16:   #else
Chris@16:           typedef detail::task_shared_state<FR,R()> task_shared_state_type;
Chris@16:   #endif
Chris@16: #else
Chris@16:           typedef detail::task_shared_state<FR,R> task_shared_state_type;
Chris@16: #endif
Chris@16:           typedef typename Allocator::template rebind<task_shared_state_type>::other A2;
Chris@16:           A2 a2(a);
Chris@16:           typedef thread_detail::allocator_destructor<A2> D;
Chris@16: 
Chris@16:           task = task_ptr(::new(a2.allocate(1)) task_shared_state_type(boost::forward<F>(f)), D(a2, 1) );
Chris@16:           future_obtained = false;
Chris@16:         }
Chris@16: #else // ! defined BOOST_NO_CXX11_RVALUE_REFERENCES
Chris@16:         template <class F, class Allocator>
Chris@16:         packaged_task(boost::allocator_arg_t, Allocator a, const F& f)
Chris@16:         {
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16:   #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:           typedef detail::task_shared_state<F,R(ArgTypes...)> task_shared_state_type;
Chris@16:   #else
Chris@16:           typedef detail::task_shared_state<F,R()> task_shared_state_type;
Chris@16:   #endif
Chris@16: #else
Chris@16:           typedef detail::task_shared_state<F,R> task_shared_state_type;
Chris@16: #endif
Chris@16:           typedef typename Allocator::template rebind<task_shared_state_type>::other A2;
Chris@16:           A2 a2(a);
Chris@16:           typedef thread_detail::allocator_destructor<A2> D;
Chris@16: 
Chris@16:           task = task_ptr(::new(a2.allocate(1)) task_shared_state_type(f), D(a2, 1) );
Chris@16:           future_obtained = false;
Chris@16:         }
Chris@16:         template <class F, class Allocator>
Chris@16:         packaged_task(boost::allocator_arg_t, Allocator a, BOOST_THREAD_RV_REF(F) f)
Chris@16:         {
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16:   #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:           typedef detail::task_shared_state<F,R(ArgTypes...)> task_shared_state_type;
Chris@16:   #else
Chris@16:           typedef detail::task_shared_state<F,R()> task_shared_state_type;
Chris@16:   #endif
Chris@16: #else
Chris@16:           typedef detail::task_shared_state<F,R> task_shared_state_type;
Chris@16: #endif
Chris@16:           typedef typename Allocator::template rebind<task_shared_state_type>::other A2;
Chris@16:           A2 a2(a);
Chris@16:           typedef thread_detail::allocator_destructor<A2> D;
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:           task = task_ptr(::new(a2.allocate(1)) task_shared_state_type(boost::forward<F>(f)), D(a2, 1) );
Chris@16: #else
Chris@16:           task = task_ptr(::new(a2.allocate(1)) task_shared_state_type(boost::move(f)), D(a2, 1) );  // TODO forward
Chris@16: #endif
Chris@16:           future_obtained = false;
Chris@16:         }
Chris@16: 
Chris@16: #endif //BOOST_NO_CXX11_RVALUE_REFERENCES
Chris@16: #endif // BOOST_THREAD_PROVIDES_FUTURE_CTOR_ALLOCATORS
Chris@16: 
Chris@16:         ~packaged_task()
Chris@16:         {
Chris@16:             if(task)
Chris@16:             {
Chris@16:                 task->owner_destroyed();
Chris@16:             }
Chris@16:         }
Chris@16: 
Chris@16:         // assignment
Chris@16:         packaged_task(BOOST_THREAD_RV_REF(packaged_task) other) BOOST_NOEXCEPT :
Chris@16:             future_obtained(BOOST_THREAD_RV(other).future_obtained)
Chris@16:         {
Chris@16:             task.swap(BOOST_THREAD_RV(other).task);
Chris@16:             BOOST_THREAD_RV(other).future_obtained=false;
Chris@16:         }
Chris@16:         packaged_task& operator=(BOOST_THREAD_RV_REF(packaged_task) other) BOOST_NOEXCEPT
Chris@16:         {
Chris@16: 
Chris@16:             // todo use forward
Chris@16: #if ! defined  BOOST_NO_CXX11_RVALUE_REFERENCES
Chris@16:             packaged_task temp(boost::move(other));
Chris@16: #else
Chris@16:             packaged_task temp(static_cast<BOOST_THREAD_RV_REF(packaged_task)>(other));
Chris@16: #endif
Chris@16:             swap(temp);
Chris@16:             return *this;
Chris@16:         }
Chris@16: 
Chris@16:         void reset()
Chris@16:         {
Chris@16:             if (!valid())
Chris@16:                 throw future_error(system::make_error_code(future_errc::no_state));
Chris@16:             task->reset();
Chris@16:             future_obtained=false;
Chris@16:         }
Chris@16: 
Chris@16:         void swap(packaged_task& other) BOOST_NOEXCEPT
Chris@16:         {
Chris@16:             task.swap(other.task);
Chris@16:             std::swap(future_obtained,other.future_obtained);
Chris@16:         }
Chris@16:         bool valid() const BOOST_NOEXCEPT
Chris@16:         {
Chris@16:           return task.get()!=0;
Chris@16:         }
Chris@16: 
Chris@16:         // result retrieval
Chris@16:         BOOST_THREAD_FUTURE<R> get_future()
Chris@16:         {
Chris@16:             if(!task)
Chris@16:             {
Chris@16:                 boost::throw_exception(task_moved());
Chris@16:             }
Chris@16:             else if(!future_obtained)
Chris@16:             {
Chris@16:                 future_obtained=true;
Chris@16:                 return BOOST_THREAD_FUTURE<R>(task);
Chris@16:             }
Chris@16:             else
Chris@16:             {
Chris@16:                 boost::throw_exception(future_already_retrieved());
Chris@16:             }
Chris@16:             //return BOOST_THREAD_FUTURE<R>();
Chris@16:         }
Chris@16: 
Chris@16:         // execution
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:         void operator()(BOOST_THREAD_RV_REF(ArgTypes)... args)
Chris@16:         {
Chris@16:             if(!task)
Chris@16:             {
Chris@16:                 boost::throw_exception(task_moved());
Chris@16:             }
Chris@16:             task->run(boost::forward<ArgTypes>(args)...);
Chris@16:         }
Chris@16:         void make_ready_at_thread_exit(ArgTypes... args)
Chris@16:         {
Chris@16:           if(!task)
Chris@16:           {
Chris@16:               boost::throw_exception(task_moved());
Chris@16:           }
Chris@16:           if (task->has_value())
Chris@16:           {
Chris@16:                 boost::throw_exception(promise_already_satisfied());
Chris@16:           }
Chris@16:           task->apply(boost::forward<ArgTypes>(args)...);
Chris@16:         }
Chris@16: #else
Chris@16:         void operator()()
Chris@16:         {
Chris@16:             if(!task)
Chris@16:             {
Chris@16:                 boost::throw_exception(task_moved());
Chris@16:             }
Chris@16:             task->run();
Chris@16:         }
Chris@16:         void make_ready_at_thread_exit()
Chris@16:         {
Chris@16:           if(!task)
Chris@16:           {
Chris@16:               boost::throw_exception(task_moved());
Chris@16:           }
Chris@16:           if (task->has_value())
Chris@16:                 boost::throw_exception(promise_already_satisfied());
Chris@16:           task->apply();
Chris@16:         }
Chris@16: #endif
Chris@16:         template<typename F>
Chris@16:         void set_wait_callback(F f)
Chris@16:         {
Chris@16:             task->set_wait_callback(f,this);
Chris@16:         }
Chris@16:     };
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_CTOR_ALLOCATORS
Chris@16:     namespace container
Chris@16:     {
Chris@16:       template <class R, class Alloc>
Chris@16:       struct uses_allocator<packaged_task<R>, Alloc>
Chris@16:         : public true_type {};
Chris@16:     }
Chris@16: #endif
Chris@16: 
Chris@16:     BOOST_THREAD_DCL_MOVABLE_BEG(T) packaged_task<T> BOOST_THREAD_DCL_MOVABLE_END
Chris@16: 
Chris@16:     namespace detail
Chris@16:     {
Chris@16:     ////////////////////////////////
Chris@16:     // make_future_deferred_shared_state
Chris@16:     ////////////////////////////////
Chris@16:     template <class Rp, class Fp>
Chris@16:     BOOST_THREAD_FUTURE<Rp>
Chris@16:     make_future_deferred_shared_state(BOOST_THREAD_FWD_REF(Fp) f)
Chris@16:     {
Chris@16:       shared_ptr<future_deferred_shared_state<Rp, Fp> >
Chris@16:           h(new future_deferred_shared_state<Rp, Fp>(boost::forward<Fp>(f)));
Chris@16:       return BOOST_THREAD_FUTURE<Rp>(h);
Chris@16:     }
Chris@16: 
Chris@16:     ////////////////////////////////
Chris@16:     // make_future_async_shared_state
Chris@16:     ////////////////////////////////
Chris@16:     template <class Rp, class Fp>
Chris@16:     BOOST_THREAD_FUTURE<Rp>
Chris@16:     make_future_async_shared_state(BOOST_THREAD_FWD_REF(Fp) f)
Chris@16:     {
Chris@16:       shared_ptr<future_async_shared_state<Rp, Fp> >
Chris@16:           h(new future_async_shared_state<Rp, Fp>(boost::forward<Fp>(f)));
Chris@16:       return BOOST_THREAD_FUTURE<Rp>(h);
Chris@16:     }
Chris@16: 
Chris@16:     }
Chris@16: 
Chris@16:     ////////////////////////////////
Chris@16:     // template <class F, class... ArgTypes>
Chris@16:     // future<R> async(launch policy, F&&, ArgTypes&&...);
Chris@16:     ////////////////////////////////
Chris@16: 
Chris@16: #if defined BOOST_THREAD_RVALUE_REFERENCES_DONT_MATCH_FUNTION_PTR
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16:   #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:         template <class R, class... ArgTypes>
Chris@16:         BOOST_THREAD_FUTURE<R>
Chris@16:         async(launch policy, R(*f)(BOOST_THREAD_FWD_REF(ArgTypes)...), BOOST_THREAD_FWD_REF(ArgTypes)... args)
Chris@16:         {
Chris@16:           typedef R(*F)(BOOST_THREAD_FWD_REF(ArgTypes)...);
Chris@16:           typedef detail::async_func<typename decay<F>::type, typename decay<ArgTypes>::type...> BF;
Chris@16:           typedef typename BF::result_type Rp;
Chris@16:   #else
Chris@16:         template <class R>
Chris@16:         BOOST_THREAD_FUTURE<R>
Chris@16:         async(launch policy, R(*f)())
Chris@16:         {
Chris@16:           typedef packaged_task<R()> packaged_task_type;
Chris@16:   #endif
Chris@16: #else
Chris@16:         template <class R>
Chris@16:         BOOST_THREAD_FUTURE<R>
Chris@16:         async(launch policy, R(*f)())
Chris@16:         {
Chris@16:           typedef packaged_task<R> packaged_task_type;
Chris@16: #endif
Chris@16:           if (int(policy) & int(launch::async))
Chris@16:             {
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:           return BOOST_THREAD_MAKE_RV_REF(boost::detail::make_future_async_shared_state<Rp>(
Chris@16:               BF(
Chris@16:                   thread_detail::decay_copy(boost::forward<F>(f))
Chris@16:                   , thread_detail::decay_copy(boost::forward<ArgTypes>(args))...
Chris@16:               )
Chris@16:           ));
Chris@16: #else
Chris@16:               packaged_task_type pt( f );
Chris@16: 
Chris@16:               BOOST_THREAD_FUTURE<R> ret = BOOST_THREAD_MAKE_RV_REF(pt.get_future());
Chris@16:               ret.set_async();
Chris@16:               boost::thread( boost::move(pt) ).detach();
Chris@16:               return ::boost::move(ret);
Chris@16: #endif
Chris@16:             }
Chris@16:             else if (int(policy) & int(launch::deferred))
Chris@16:             {
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:           return BOOST_THREAD_MAKE_RV_REF(boost::detail::make_future_deferred_shared_state<Rp>(
Chris@16:               BF(
Chris@16:                   thread_detail::decay_copy(boost::forward<F>(f))
Chris@16:                   , thread_detail::decay_copy(boost::forward<ArgTypes>(args))...
Chris@16:               )
Chris@16:           ));
Chris@16: #else
Chris@16:           std::terminate();
Chris@16:           BOOST_THREAD_FUTURE<R> ret;
Chris@16:           return ::boost::move(ret);
Chris@16: 
Chris@16: #endif
Chris@16:             } else {
Chris@16:               std::terminate();
Chris@16:               BOOST_THREAD_FUTURE<R> ret;
Chris@16:               return ::boost::move(ret);
Chris@16:             }
Chris@16:         }
Chris@16: 
Chris@16: #endif
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK
Chris@16:   #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16: 
Chris@16:         template <class F, class ...ArgTypes>
Chris@16:         BOOST_THREAD_FUTURE<typename boost::result_of<typename decay<F>::type(
Chris@16:             typename decay<ArgTypes>::type...
Chris@16:         )>::type>
Chris@16:         async(launch policy, BOOST_THREAD_FWD_REF(F) f, BOOST_THREAD_FWD_REF(ArgTypes)... args)
Chris@16:         {
Chris@16: 
Chris@16:           typedef typename boost::result_of<typename decay<F>::type(
Chris@16:               typename decay<ArgTypes>::type...
Chris@16:           )>::type R;
Chris@16: 
Chris@16:           typedef detail::async_func<typename decay<F>::type, typename decay<ArgTypes>::type...> BF;
Chris@16:           typedef typename BF::result_type Rp;
Chris@16: 
Chris@16:   #else
Chris@16:         template <class F>
Chris@16:         BOOST_THREAD_FUTURE<typename boost::result_of<typename decay<F>::type()>::type>
Chris@16:         async(launch policy, BOOST_THREAD_FWD_REF(F)  f)
Chris@16:         {
Chris@16:           typedef typename boost::result_of<typename decay<F>::type()>::type R;
Chris@16:           typedef packaged_task<R()> packaged_task_type;
Chris@16: 
Chris@16:   #endif
Chris@16: #else
Chris@16:         template <class F>
Chris@16:         BOOST_THREAD_FUTURE<typename boost::result_of<typename decay<F>::type()>::type>
Chris@16:         async(launch policy, BOOST_THREAD_FWD_REF(F)  f)
Chris@16:         {
Chris@16:           typedef typename boost::result_of<typename decay<F>::type()>::type R;
Chris@16:           typedef packaged_task<R> packaged_task_type;
Chris@16: 
Chris@16: #endif
Chris@16: 
Chris@16:         if (int(policy) & int(launch::async))
Chris@16:         {
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:           return BOOST_THREAD_MAKE_RV_REF(boost::detail::make_future_async_shared_state<Rp>(
Chris@16:               BF(
Chris@16:                   thread_detail::decay_copy(boost::forward<F>(f))
Chris@16:                   , thread_detail::decay_copy(boost::forward<ArgTypes>(args))...
Chris@16:               )
Chris@16:           ));
Chris@16: #else
Chris@16:           packaged_task_type pt( boost::forward<F>(f) );
Chris@16: 
Chris@16:           BOOST_THREAD_FUTURE<R> ret = pt.get_future();
Chris@16:           ret.set_async();
Chris@16:           boost::thread( boost::move(pt) ).detach();
Chris@16:           return ::boost::move(ret);
Chris@16: #endif
Chris@16:         }
Chris@16:         else if (int(policy) & int(launch::deferred))
Chris@16:         {
Chris@16: #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:           return BOOST_THREAD_MAKE_RV_REF(boost::detail::make_future_deferred_shared_state<Rp>(
Chris@16:               BF(
Chris@16:                   thread_detail::decay_copy(boost::forward<F>(f))
Chris@16:                   , thread_detail::decay_copy(boost::forward<ArgTypes>(args))...
Chris@16:               )
Chris@16:           ));
Chris@16: #else
Chris@16:               std::terminate();
Chris@16:               BOOST_THREAD_FUTURE<R> ret;
Chris@16:               return ::boost::move(ret);
Chris@16: //          return boost::detail::make_future_deferred_shared_state<Rp>(
Chris@16: //              BF(
Chris@16: //                  thread_detail::decay_copy(boost::forward<F>(f))
Chris@16: //              )
Chris@16: //          );
Chris@16: #endif
Chris@16: 
Chris@16:         } else {
Chris@16:           std::terminate();
Chris@16:           BOOST_THREAD_FUTURE<R> ret;
Chris@16:           return ::boost::move(ret);
Chris@16:         }
Chris@16:     }
Chris@16: 
Chris@16:         ////////////////////////////////
Chris@16:         // template <class F, class... ArgTypes>
Chris@16:         // future<R> async(F&&, ArgTypes&&...);
Chris@16:         ////////////////////////////////
Chris@16: 
Chris@16:     #if defined BOOST_THREAD_RVALUE_REFERENCES_DONT_MATCH_FUNTION_PTR
Chris@16: 
Chris@16:     #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:             template <class R, class... ArgTypes>
Chris@16:             BOOST_THREAD_FUTURE<R>
Chris@16:             async(R(*f)(BOOST_THREAD_FWD_REF(ArgTypes)...), BOOST_THREAD_FWD_REF(ArgTypes)... args)
Chris@16:             {
Chris@16:               return BOOST_THREAD_MAKE_RV_REF(async(launch(launch::any), f, boost::forward<ArgTypes>(args)...));
Chris@16:             }
Chris@16:     #else
Chris@16:             template <class R>
Chris@16:             BOOST_THREAD_FUTURE<R>
Chris@16:             async(R(*f)())
Chris@16:             {
Chris@16:               return BOOST_THREAD_MAKE_RV_REF(async(launch(launch::any), f));
Chris@16:             }
Chris@16:     #endif
Chris@16:     #endif
Chris@16: 
Chris@16:     #if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
Chris@16:             template <class F, class ...ArgTypes>
Chris@16:             BOOST_THREAD_FUTURE<typename boost::result_of<typename decay<F>::type(
Chris@16:                 typename decay<ArgTypes>::type...
Chris@16:             )>::type>
Chris@16:             async(BOOST_THREAD_FWD_REF(F) f, BOOST_THREAD_FWD_REF(ArgTypes)... args)
Chris@16:             {
Chris@16:                 return BOOST_THREAD_MAKE_RV_REF(async(launch(launch::any), boost::forward<F>(f), boost::forward<ArgTypes>(args)...));
Chris@16:             }
Chris@16:     #else
Chris@16:     template <class F>
Chris@16:     BOOST_THREAD_FUTURE<typename boost::result_of<F()>::type>
Chris@16:     async(BOOST_THREAD_RV_REF(F) f)
Chris@16:     {
Chris@16:         return BOOST_THREAD_MAKE_RV_REF(async(launch(launch::any), boost::forward<F>(f)));
Chris@16:     }
Chris@16: #endif
Chris@16: 
Chris@16: 
Chris@16:   ////////////////////////////////
Chris@16:   // make_future deprecated
Chris@16:   ////////////////////////////////
Chris@16:   template <typename T>
Chris@16:   BOOST_THREAD_FUTURE<typename decay<T>::type> make_future(BOOST_THREAD_FWD_REF(T) value)
Chris@16:   {
Chris@16:     typedef typename decay<T>::type future_value_type;
Chris@16:     promise<future_value_type> p;
Chris@16:     p.set_value(boost::forward<future_value_type>(value));
Chris@16:     return BOOST_THREAD_MAKE_RV_REF(p.get_future());
Chris@16:   }
Chris@16: 
Chris@16: #if defined BOOST_THREAD_USES_MOVE
Chris@16:   inline BOOST_THREAD_FUTURE<void> make_future()
Chris@16:   {
Chris@16:     promise<void> p;
Chris@16:     p.set_value();
Chris@16:     return BOOST_THREAD_MAKE_RV_REF(p.get_future());
Chris@16:   }
Chris@16: #endif
Chris@16: 
Chris@16:   ////////////////////////////////
Chris@16:   // make_ready_future
Chris@16:   ////////////////////////////////
Chris@16:   template <typename T>
Chris@16:   BOOST_THREAD_FUTURE<typename decay<T>::type> make_ready_future(BOOST_THREAD_FWD_REF(T) value)
Chris@16:   {
Chris@16:     typedef typename decay<T>::type future_value_type;
Chris@16:     promise<future_value_type> p;
Chris@16:     p.set_value(boost::forward<future_value_type>(value));
Chris@16:     return BOOST_THREAD_MAKE_RV_REF(p.get_future());
Chris@16:   }
Chris@16: 
Chris@16: #if defined BOOST_THREAD_USES_MOVE
Chris@16:   inline BOOST_THREAD_FUTURE<void> make_ready_future()
Chris@16:   {
Chris@16:     promise<void> p;
Chris@16:     p.set_value();
Chris@16:     return BOOST_THREAD_MAKE_RV_REF(p.get_future());
Chris@16:   }
Chris@16: #endif
Chris@16: 
Chris@16:   template <typename T>
Chris@16:   BOOST_THREAD_FUTURE<T> make_ready_future(exception_ptr ex)
Chris@16:   {
Chris@16:     promise<T> p;
Chris@16:     p.set_exception(ex);
Chris@16:     return BOOST_THREAD_MAKE_RV_REF(p.get_future());
Chris@16:   }
Chris@16:   template <typename T, typename E>
Chris@16:   BOOST_THREAD_FUTURE<T> make_ready_future(E ex)
Chris@16:   {
Chris@16:     promise<T> p;
Chris@16:     p.set_exception(boost::copy_exception(ex));
Chris@16:     return BOOST_THREAD_MAKE_RV_REF(p.get_future());
Chris@16:   }
Chris@16: 
Chris@16: #if 0
Chris@16:   template<typename CLOSURE>
Chris@16:   make_future(CLOSURE closure) -> BOOST_THREAD_FUTURE<decltype(closure())> {
Chris@16:       typedef decltype(closure()) T;
Chris@16:       promise<T> p;
Chris@16:       try
Chris@16:       {
Chris@16:         p.set_value(closure());
Chris@16:       }
Chris@16:       catch(...)
Chris@16:       {
Chris@16:         p.set_exception(std::current_exception());
Chris@16:       }
Chris@16:       return BOOST_THREAD_MAKE_RV_REF(p.get_future());
Chris@16:   }
Chris@16: #endif
Chris@16: 
Chris@16:   ////////////////////////////////
Chris@16:   // make_shared_future deprecated
Chris@16:   ////////////////////////////////
Chris@16:   template <typename T>
Chris@16:   shared_future<typename decay<T>::type> make_shared_future(BOOST_THREAD_FWD_REF(T) value)
Chris@16:   {
Chris@16:     typedef typename decay<T>::type future_type;
Chris@16:     promise<future_type> p;
Chris@16:     p.set_value(boost::forward<T>(value));
Chris@16:     return BOOST_THREAD_MAKE_RV_REF(p.get_future().share());
Chris@16:   }
Chris@16: 
Chris@16: 
Chris@16:   inline shared_future<void> make_shared_future()
Chris@16:   {
Chris@16:     promise<void> p;
Chris@16:     return BOOST_THREAD_MAKE_RV_REF(p.get_future().share());
Chris@16: 
Chris@16:   }
Chris@16: 
Chris@16: //  ////////////////////////////////
Chris@16: //  // make_ready_shared_future
Chris@16: //  ////////////////////////////////
Chris@16: //  template <typename T>
Chris@16: //  shared_future<typename decay<T>::type> make_ready_shared_future(BOOST_THREAD_FWD_REF(T) value)
Chris@16: //  {
Chris@16: //    typedef typename decay<T>::type future_type;
Chris@16: //    promise<future_type> p;
Chris@16: //    p.set_value(boost::forward<T>(value));
Chris@16: //    return p.get_future().share();
Chris@16: //  }
Chris@16: //
Chris@16: //
Chris@16: //  inline shared_future<void> make_ready_shared_future()
Chris@16: //  {
Chris@16: //    promise<void> p;
Chris@16: //    return BOOST_THREAD_MAKE_RV_REF(p.get_future().share());
Chris@16: //
Chris@16: //  }
Chris@16: //
Chris@16: //  ////////////////////////////////
Chris@16: //  // make_exceptional_shared_future
Chris@16: //  ////////////////////////////////
Chris@16: //  template <typename T>
Chris@16: //  shared_future<T> make_exceptional_shared_future(exception_ptr ex)
Chris@16: //  {
Chris@16: //    promise<T> p;
Chris@16: //    p.set_exception(ex);
Chris@16: //    return p.get_future().share();
Chris@16: //  }
Chris@16: 
Chris@16:   ////////////////////////////////
Chris@16:   // detail::future_async_continuation_shared_state
Chris@16:   ////////////////////////////////
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION
Chris@16:   namespace detail
Chris@16:   {
Chris@16: 
Chris@16:     /////////////////////////
Chris@16:     /// future_async_continuation_shared_state
Chris@16:     /////////////////////////
Chris@16: 
Chris@16:     template<typename F, typename Rp, typename Fp>
Chris@16:     struct future_async_continuation_shared_state: future_async_shared_state_base<Rp>
Chris@16:     {
Chris@16:       F parent;
Chris@16:       Fp continuation;
Chris@16: 
Chris@16:     public:
Chris@16:       future_async_continuation_shared_state(
Chris@16:           BOOST_THREAD_RV_REF(F) f, BOOST_THREAD_FWD_REF(Fp) c
Chris@16:           ) :
Chris@16:       parent(boost::move(f)),
Chris@16:       continuation(boost::move(c))
Chris@16:       {
Chris@16:       }
Chris@16: 
Chris@16:       void launch_continuation(boost::unique_lock<boost::mutex>& lock)
Chris@16:       {
Chris@16:         lock.unlock();
Chris@16:         this->thr_ = thread(&future_async_continuation_shared_state::run, this);
Chris@16:       }
Chris@16: 
Chris@16:       static void run(future_async_continuation_shared_state* that)
Chris@16:       {
Chris@16:         try
Chris@16:         {
Chris@16:           that->mark_finished_with_result(that->continuation(boost::move(that->parent)));
Chris@16:         }
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:         catch(thread_interrupted& )
Chris@16:         {
Chris@16:           that->mark_interrupted_finish();
Chris@16:         }
Chris@16: #endif
Chris@16:         catch(...)
Chris@16:         {
Chris@16:           that->mark_exceptional_finish();
Chris@16:         }
Chris@16:       }
Chris@16:       ~future_async_continuation_shared_state()
Chris@16:       {
Chris@16:         this->join();
Chris@16:       }
Chris@16:     };
Chris@16: 
Chris@16:     template<typename F, typename Fp>
Chris@16:     struct future_async_continuation_shared_state<F, void, Fp>: public future_async_shared_state_base<void>
Chris@16:     {
Chris@16:       F parent;
Chris@16:       Fp continuation;
Chris@16: 
Chris@16:     public:
Chris@16:       future_async_continuation_shared_state(
Chris@16:           BOOST_THREAD_RV_REF(F) f, BOOST_THREAD_FWD_REF(Fp) c
Chris@16:           ) :
Chris@16:             parent(boost::move(f)),
Chris@16:       continuation(boost::move(c))
Chris@16:       {
Chris@16:       }
Chris@16: 
Chris@16:       void launch_continuation(boost::unique_lock<boost::mutex>& lk)
Chris@16:       {
Chris@16:         lk.unlock();
Chris@16:         this->thr_ = thread(&future_async_continuation_shared_state::run, this);
Chris@16:       }
Chris@16: 
Chris@16:       static void run(future_async_continuation_shared_state* that)
Chris@16:       {
Chris@16:         try
Chris@16:         {
Chris@16:           that->continuation(boost::move(that->parent));
Chris@16:           that->mark_finished_with_result();
Chris@16:         }
Chris@16: #if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
Chris@16:         catch(thread_interrupted& )
Chris@16:         {
Chris@16:           that->mark_interrupted_finish();
Chris@16:         }
Chris@16: #endif
Chris@16:         catch(...)
Chris@16:         {
Chris@16:           that->mark_exceptional_finish();
Chris@16:         }
Chris@16:       }
Chris@16:       ~future_async_continuation_shared_state()
Chris@16:       {
Chris@16:         this->join();
Chris@16:       }
Chris@16:     };
Chris@16: 
Chris@16: 
Chris@16:     //////////////////////////
Chris@16:     /// future_deferred_continuation_shared_state
Chris@16:     //////////////////////////
Chris@16:     template<typename F, typename Rp, typename Fp>
Chris@16:     struct future_deferred_continuation_shared_state: shared_state<Rp>
Chris@16:     {
Chris@16:       F parent;
Chris@16:       Fp continuation;
Chris@16: 
Chris@16:     public:
Chris@16:       future_deferred_continuation_shared_state(
Chris@16:           BOOST_THREAD_RV_REF(F) f, BOOST_THREAD_FWD_REF(Fp) c
Chris@16:           ) :
Chris@16:           parent(boost::move(f)),
Chris@16:           continuation(boost::move(c))
Chris@16:       {
Chris@16:         this->set_deferred();
Chris@16:       }
Chris@16: 
Chris@16:       virtual void launch_continuation(boost::unique_lock<boost::mutex>& lk)
Chris@16:       {
Chris@16:         execute(lk);
Chris@16:       }
Chris@16: 
Chris@16:       virtual void execute(boost::unique_lock<boost::mutex>& lck) {
Chris@16:         try
Chris@16:         {
Chris@16:           Fp local_fuct=boost::move(continuation);
Chris@16:           F ftmp = boost::move(parent);
Chris@16:           relocker relock(lck);
Chris@16:           Rp res = local_fuct(boost::move(ftmp));
Chris@16:           relock.lock();
Chris@16:           this->mark_finished_with_result_internal(boost::move(res), lck);
Chris@16:         }
Chris@16:         catch (...)
Chris@16:         {
Chris@16:           this->mark_exceptional_finish_internal(current_exception(), lck);
Chris@16:         }
Chris@16:       }
Chris@16:     };
Chris@16: 
Chris@16:     template<typename F, typename Fp>
Chris@16:     struct future_deferred_continuation_shared_state<F,void,Fp>: shared_state<void>
Chris@16:     {
Chris@16:       F parent;
Chris@16:       Fp continuation;
Chris@16: 
Chris@16:     public:
Chris@16:       future_deferred_continuation_shared_state(
Chris@16:           BOOST_THREAD_RV_REF(F) f, BOOST_THREAD_FWD_REF(Fp) c
Chris@16:           ):
Chris@16:           parent(boost::move(f)),
Chris@16:           continuation(boost::move(c))
Chris@16:       {
Chris@16:         this->set_deferred();
Chris@16:       }
Chris@16: 
Chris@16:       virtual void launch_continuation(boost::unique_lock<boost::mutex>& lk)
Chris@16:       {
Chris@16:         execute(lk);
Chris@16:       }
Chris@16:       virtual void execute(boost::unique_lock<boost::mutex>& lck) {
Chris@16:         try
Chris@16:         {
Chris@16:           Fp local_fuct=boost::move(continuation);
Chris@16:           F ftmp = boost::move(parent);
Chris@16:           relocker relock(lck);
Chris@16:           local_fuct(boost::move(ftmp));
Chris@16:           relock.lock();
Chris@16:           this->mark_finished_with_result_internal(lck);
Chris@16:         }
Chris@16:         catch (...)
Chris@16:         {
Chris@16:           this->mark_exceptional_finish_internal(current_exception(), lck);
Chris@16:         }
Chris@16:       }
Chris@16:     };
Chris@16: 
Chris@16:     ////////////////////////////////
Chris@16:     // make_future_deferred_continuation_shared_state
Chris@16:     ////////////////////////////////
Chris@16:     template<typename F, typename Rp, typename Fp>
Chris@16:     BOOST_THREAD_FUTURE<Rp>
Chris@16:     make_future_deferred_continuation_shared_state(
Chris@16:         boost::unique_lock<boost::mutex> &lock,
Chris@16:         BOOST_THREAD_RV_REF(F) f, BOOST_THREAD_FWD_REF(Fp) c
Chris@16:         )
Chris@16:     {
Chris@16:       shared_ptr<future_deferred_continuation_shared_state<F, Rp, Fp> >
Chris@16:           h(new future_deferred_continuation_shared_state<F, Rp, Fp>(boost::move(f), boost::forward<Fp>(c)));
Chris@16:       h->parent.future_->set_continuation_ptr(h, lock);
Chris@16:       return BOOST_THREAD_FUTURE<Rp>(h);
Chris@16:     }
Chris@16: 
Chris@16:     ////////////////////////////////
Chris@16:     // make_future_async_continuation_shared_state
Chris@16:     ////////////////////////////////
Chris@16:     template<typename F, typename Rp, typename Fp>
Chris@16:     BOOST_THREAD_FUTURE<Rp>
Chris@16:     make_future_async_continuation_shared_state(
Chris@16:         boost::unique_lock<boost::mutex> &lock, BOOST_THREAD_RV_REF(F) f, BOOST_THREAD_FWD_REF(Fp) c
Chris@16:         )
Chris@16:     {
Chris@16:       shared_ptr<future_async_continuation_shared_state<F,Rp, Fp> >
Chris@16:           h(new future_async_continuation_shared_state<F,Rp, Fp>(boost::move(f), boost::forward<Fp>(c)));
Chris@16:       h->parent.future_->set_continuation_ptr(h, lock);
Chris@16: 
Chris@16:       return BOOST_THREAD_FUTURE<Rp>(h);
Chris@16:     }
Chris@16: 
Chris@16:   }
Chris@16: 
Chris@16:   ////////////////////////////////
Chris@16:   // template<typename F>
Chris@16:   // auto future<R>::then(F&& func) -> BOOST_THREAD_FUTURE<decltype(func(*this))>;
Chris@16:   ////////////////////////////////
Chris@16: 
Chris@16:   template <typename R>
Chris@16:   template <typename F>
Chris@16:   inline BOOST_THREAD_FUTURE<typename boost::result_of<F(BOOST_THREAD_FUTURE<R>)>::type>
Chris@16:   BOOST_THREAD_FUTURE<R>::then(launch policy, BOOST_THREAD_FWD_REF(F) func)
Chris@16:   {
Chris@16: 
Chris@16:     typedef typename boost::result_of<F(BOOST_THREAD_FUTURE<R>)>::type future_type;
Chris@16:     BOOST_THREAD_ASSERT_PRECONDITION(this->future_!=0, future_uninitialized());
Chris@16: 
Chris@16:     boost::unique_lock<boost::mutex> lock(this->future_->mutex);
Chris@16:     if (int(policy) & int(launch::async))
Chris@16:     {
Chris@16:       return BOOST_THREAD_MAKE_RV_REF((boost::detail::make_future_async_continuation_shared_state<BOOST_THREAD_FUTURE<R>, future_type, F>(
Chris@16:                   lock, boost::move(*this), boost::forward<F>(func)
Chris@16:               )));
Chris@16:     }
Chris@16:     else if (int(policy) & int(launch::deferred))
Chris@16:     {
Chris@16:       return BOOST_THREAD_MAKE_RV_REF((boost::detail::make_future_deferred_continuation_shared_state<BOOST_THREAD_FUTURE<R>, future_type, F>(
Chris@16:                   lock, boost::move(*this), boost::forward<F>(func)
Chris@16:               )));
Chris@16:     }
Chris@16:     else
Chris@16:     {
Chris@16:       return BOOST_THREAD_MAKE_RV_REF((boost::detail::make_future_async_continuation_shared_state<BOOST_THREAD_FUTURE<R>, future_type, F>(
Chris@16:                   lock, boost::move(*this), boost::forward<F>(func)
Chris@16:               )));
Chris@16: 
Chris@16:     }
Chris@16: 
Chris@16:   }
Chris@16:   template <typename R>
Chris@16:   template <typename F>
Chris@16:   inline BOOST_THREAD_FUTURE<typename boost::result_of<F(BOOST_THREAD_FUTURE<R>)>::type>
Chris@16:   BOOST_THREAD_FUTURE<R>::then(BOOST_THREAD_FWD_REF(F) func)
Chris@16:   {
Chris@16: 
Chris@16:     typedef typename boost::result_of<F(BOOST_THREAD_FUTURE<R>)>::type future_type;
Chris@16:     BOOST_THREAD_ASSERT_PRECONDITION(this->future_!=0, future_uninitialized());
Chris@16: 
Chris@16:     boost::unique_lock<boost::mutex> lock(this->future_->mutex);
Chris@16:     if (int(this->launch_policy(lock)) & int(launch::async))
Chris@16:     {
Chris@16:       return boost::detail::make_future_async_continuation_shared_state<BOOST_THREAD_FUTURE<R>, future_type, F>(
Chris@16:           lock, boost::move(*this), boost::forward<F>(func)
Chris@16:       );
Chris@16:     }
Chris@16:     else if (int(this->launch_policy(lock)) & int(launch::deferred))
Chris@16:     {
Chris@16:       this->future_->wait_internal(lock);
Chris@16:       return boost::detail::make_future_deferred_continuation_shared_state<BOOST_THREAD_FUTURE<R>, future_type, F>(
Chris@16:           lock, boost::move(*this), boost::forward<F>(func)
Chris@16:       );
Chris@16:     }
Chris@16:     else
Chris@16:     {
Chris@16:       return boost::detail::make_future_async_continuation_shared_state<BOOST_THREAD_FUTURE<R>, future_type, F>(
Chris@16:           lock, boost::move(*this), boost::forward<F>(func)
Chris@16:       );
Chris@16:     }
Chris@16:   }
Chris@16: 
Chris@16: 
Chris@16: //#if 0 && defined(BOOST_THREAD_RVALUE_REFERENCES_DONT_MATCH_FUNTION_PTR)
Chris@16: //  template <typename R>
Chris@16: //  template<typename RF>
Chris@16: //  BOOST_THREAD_FUTURE<RF>
Chris@16: //  BOOST_THREAD_FUTURE<R>::then(RF(*func)(BOOST_THREAD_FUTURE<R>&))
Chris@16: //  {
Chris@16: //
Chris@16: //    typedef RF future_type;
Chris@16: //
Chris@16: //    if (this->future_)
Chris@16: //    {
Chris@16: //      boost::unique_lock<boost::mutex> lock(this->future_->mutex);
Chris@16: //      detail::future_continuation<BOOST_THREAD_FUTURE<R>, future_type, RF(*)(BOOST_THREAD_FUTURE&) > *ptr =
Chris@16: //          new detail::future_continuation<BOOST_THREAD_FUTURE<R>, future_type, RF(*)(BOOST_THREAD_FUTURE&)>(*this, func);
Chris@16: //      if (ptr==0)
Chris@16: //      {
Chris@16: //        return BOOST_THREAD_MAKE_RV_REF(BOOST_THREAD_FUTURE<future_type>());
Chris@16: //      }
Chris@16: //      this->future_->set_continuation_ptr(ptr, lock);
Chris@16: //      return ptr->get_future();
Chris@16: //    } else {
Chris@16: //      // fixme what to do when the future has no associated state?
Chris@16: //      return BOOST_THREAD_MAKE_RV_REF(BOOST_THREAD_FUTURE<future_type>());
Chris@16: //    }
Chris@16: //
Chris@16: //  }
Chris@16: //  template <typename R>
Chris@16: //  template<typename RF>
Chris@16: //  BOOST_THREAD_FUTURE<RF>
Chris@16: //  BOOST_THREAD_FUTURE<R>::then(launch policy, RF(*func)(BOOST_THREAD_FUTURE<R>&))
Chris@16: //  {
Chris@16: //
Chris@16: //    typedef RF future_type;
Chris@16: //
Chris@16: //    if (this->future_)
Chris@16: //    {
Chris@16: //      boost::unique_lock<boost::mutex> lock(this->future_->mutex);
Chris@16: //      detail::future_continuation<BOOST_THREAD_FUTURE<R>, future_type, RF(*)(BOOST_THREAD_FUTURE&) > *ptr =
Chris@16: //          new detail::future_continuation<BOOST_THREAD_FUTURE<R>, future_type, RF(*)(BOOST_THREAD_FUTURE&)>(*this, func, policy);
Chris@16: //      if (ptr==0)
Chris@16: //      {
Chris@16: //        return BOOST_THREAD_MAKE_RV_REF(BOOST_THREAD_FUTURE<future_type>());
Chris@16: //      }
Chris@16: //      this->future_->set_continuation_ptr(ptr, lock);
Chris@16: //      return ptr->get_future();
Chris@16: //    } else {
Chris@16: //      // fixme what to do when the future has no associated state?
Chris@16: //      return BOOST_THREAD_MAKE_RV_REF(BOOST_THREAD_FUTURE<future_type>());
Chris@16: //    }
Chris@16: //
Chris@16: //  }
Chris@16: //#endif
Chris@16: 
Chris@16:   template <typename R>
Chris@16:   template <typename F>
Chris@16:   inline BOOST_THREAD_FUTURE<typename boost::result_of<F(shared_future<R>)>::type>
Chris@16:   shared_future<R>::then(launch policy, BOOST_THREAD_FWD_REF(F) func)
Chris@16:   {
Chris@16: 
Chris@16:     typedef typename boost::result_of<F(shared_future<R>)>::type future_type;
Chris@16:     BOOST_THREAD_ASSERT_PRECONDITION(this->future_!=0, future_uninitialized());
Chris@16: 
Chris@16:     boost::unique_lock<boost::mutex> lock(this->future_->mutex);
Chris@16:     if (int(policy) & int(launch::async))
Chris@16:     {
Chris@16:       return BOOST_THREAD_MAKE_RV_REF((boost::detail::make_future_async_continuation_shared_state<shared_future<R>, future_type, F>(
Chris@16:                   lock, boost::move(*this), boost::forward<F>(func)
Chris@16:               )));
Chris@16:     }
Chris@16:     else if (int(policy) & int(launch::deferred))
Chris@16:     {
Chris@16:       return BOOST_THREAD_MAKE_RV_REF((boost::detail::make_future_deferred_continuation_shared_state<shared_future<R>, future_type, F>(
Chris@16:                   lock, boost::move(*this), boost::forward<F>(func)
Chris@16:               )));
Chris@16:     }
Chris@16:     else
Chris@16:     {
Chris@16:       return BOOST_THREAD_MAKE_RV_REF((boost::detail::make_future_async_continuation_shared_state<shared_future<R>, future_type, F>(
Chris@16:                   lock, boost::move(*this), boost::forward<F>(func)
Chris@16:               )));
Chris@16:     }
Chris@16: 
Chris@16:   }
Chris@16:   template <typename R>
Chris@16:   template <typename F>
Chris@16:   inline BOOST_THREAD_FUTURE<typename boost::result_of<F(shared_future<R>)>::type>
Chris@16:   shared_future<R>::then(BOOST_THREAD_FWD_REF(F) func)
Chris@16:   {
Chris@16: 
Chris@16:     typedef typename boost::result_of<F(shared_future<R>)>::type future_type;
Chris@16: 
Chris@16:     BOOST_THREAD_ASSERT_PRECONDITION(this->future_!=0, future_uninitialized());
Chris@16: 
Chris@16:     boost::unique_lock<boost::mutex> lock(this->future_->mutex);
Chris@16:     if (int(this->launch_policy(lock)) & int(launch::async))
Chris@16:     {
Chris@16:       return boost::detail::make_future_async_continuation_shared_state<shared_future<R>, future_type, F>(
Chris@16:           lock, boost::move(*this), boost::forward<F>(func)
Chris@16:       );
Chris@16:     }
Chris@16:     else if (int(this->launch_policy(lock)) & int(launch::deferred))
Chris@16:     {
Chris@16:       this->future_->wait_internal(lock);
Chris@16:       return boost::detail::make_future_deferred_continuation_shared_state<shared_future<R>, future_type, F>(
Chris@16:           lock, boost::move(*this), boost::forward<F>(func)
Chris@16:       );
Chris@16:     }
Chris@16:     else
Chris@16:     {
Chris@16:       return boost::detail::make_future_async_continuation_shared_state<shared_future<R>, future_type, F>(
Chris@16:           lock, boost::move(*this), boost::forward<F>(func)
Chris@16:       );
Chris@16:     }
Chris@16:   }
Chris@16:   namespace detail
Chris@16:   {
Chris@16:     template <typename T>
Chris@16:     struct mfallbacker_to
Chris@16:     {
Chris@16:       T value_;
Chris@16:       typedef T result_type;
Chris@16:       mfallbacker_to(BOOST_THREAD_RV_REF(T) v)
Chris@16:       : value_(boost::move(v))
Chris@16:       {}
Chris@16: 
Chris@16:       T operator()(BOOST_THREAD_FUTURE<T> fut)
Chris@16:       {
Chris@16:         return fut.get_or(boost::move(value_));
Chris@16: 
Chris@16:       }
Chris@16:     };
Chris@16:     template <typename T>
Chris@16:     struct cfallbacker_to
Chris@16:     {
Chris@16:       T value_;
Chris@16:       typedef T result_type;
Chris@16:       cfallbacker_to(T const& v)
Chris@16:       : value_(v)
Chris@16:       {}
Chris@16: 
Chris@16:       T operator()(BOOST_THREAD_FUTURE<T> fut)
Chris@16:       {
Chris@16:         return fut.get_or(value_);
Chris@16: 
Chris@16:       }
Chris@16:     };
Chris@16:   }
Chris@16:   ////////////////////////////////
Chris@16:   // future<R> future<R>::fallback_to(R&& v);
Chris@16:   ////////////////////////////////
Chris@16: 
Chris@16:   template <typename R>
Chris@16:   template <typename R2>
Chris@16:   inline typename boost::disable_if< is_void<R2>, BOOST_THREAD_FUTURE<R> >::type
Chris@16:   BOOST_THREAD_FUTURE<R>::fallback_to(BOOST_THREAD_RV_REF(R2) v)
Chris@16:   {
Chris@16:     return then(detail::mfallbacker_to<R>(boost::move(v)));
Chris@16:   }
Chris@16: 
Chris@16:   template <typename R>
Chris@16:   template <typename R2>
Chris@16:   inline typename boost::disable_if< is_void<R2>, BOOST_THREAD_FUTURE<R> >::type
Chris@16:   BOOST_THREAD_FUTURE<R>::fallback_to(R2 const& v)
Chris@16:   {
Chris@16:     return then(detail::cfallbacker_to<R>(v));
Chris@16:   }
Chris@16: 
Chris@16: #endif
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_FUTURE_UNWRAP
Chris@16:   namespace detail
Chris@16:   {
Chris@16: 
Chris@16:     /////////////////////////
Chris@16:     /// future_unwrap_shared_state
Chris@16:     /////////////////////////
Chris@16: 
Chris@16:     template<typename F, typename Rp>
Chris@16:     struct future_unwrap_shared_state: shared_state<Rp>
Chris@16:     {
Chris@16:       F parent;
Chris@16:     public:
Chris@16:       explicit future_unwrap_shared_state(
Chris@16:           BOOST_THREAD_RV_REF(F) f
Chris@16:           ) :
Chris@16:       parent(boost::move(f))
Chris@16:       {
Chris@16:       }
Chris@16:       virtual void wait(bool ) // todo see if rethrow must be used
Chris@16:       {
Chris@16:           boost::unique_lock<boost::mutex> lock(mutex);
Chris@16:           parent.get().wait();
Chris@16:       }
Chris@16:       virtual Rp get()
Chris@16:       {
Chris@16:           boost::unique_lock<boost::mutex> lock(mutex);
Chris@16:           return parent.get().get();
Chris@16:       }
Chris@16: 
Chris@16:     };
Chris@16: 
Chris@16:     template <class F, class Rp>
Chris@16:     BOOST_THREAD_FUTURE<Rp>
Chris@16:     make_future_unwrap_shared_state(boost::unique_lock<boost::mutex> &lock, BOOST_THREAD_RV_REF(F) f)
Chris@16:     {
Chris@16:       shared_ptr<future_unwrap_shared_state<F, Rp> >
Chris@16:           h(new future_unwrap_shared_state<F, Rp>(boost::move(f)));
Chris@16:       h->parent.future_->set_continuation_ptr(h, lock);
Chris@16:       return BOOST_THREAD_FUTURE<Rp>(h);
Chris@16:     }
Chris@16:   }
Chris@16: 
Chris@16:   template <typename R>
Chris@16:   inline BOOST_THREAD_FUTURE<R>::BOOST_THREAD_FUTURE(BOOST_THREAD_RV_REF(BOOST_THREAD_FUTURE<BOOST_THREAD_FUTURE<R> >) other):
Chris@16:   base_type(other.unwrap())
Chris@16:   {
Chris@16:   }
Chris@16: 
Chris@16:   template <typename R2>
Chris@16:   BOOST_THREAD_FUTURE<R2>
Chris@16:   BOOST_THREAD_FUTURE<BOOST_THREAD_FUTURE<R2> >::unwrap()
Chris@16:   {
Chris@16:     BOOST_THREAD_ASSERT_PRECONDITION(this->future_!=0, future_uninitialized());
Chris@16:     boost::unique_lock<boost::mutex> lock(this->future_->mutex);
Chris@16:     return boost::detail::make_future_unwrap_shared_state<BOOST_THREAD_FUTURE<BOOST_THREAD_FUTURE<R2> >, R2>(lock, boost::move(*this));
Chris@16:   }
Chris@16: #endif
Chris@16: }
Chris@16: 
Chris@16: #endif // BOOST_NO_EXCEPTION
Chris@16: #endif // header