Re: [Boost-bugs] [Boost C++ Libraries] #11256: future<>::is_ready() == false in continuation function

Subject: Re: [Boost-bugs] [Boost C++ Libraries] #11256: future<>::is_ready() == false in continuation function
From: Boost C++ Libraries (noreply_at_[hidden])
Date: 2015-05-03 20:53:26

#11256: future<>::is_ready() == false in continuation function
-------------------------------------+-------------------------------------
  Reporter:  Konrad Zemek            |      Owner:  viboes
  <konrad.zemek@…>                   |     Status:  assigned
      Type:  Bugs                    |  Component:  thread
 Milestone:  To Be Determined        |   Severity:  Problem
   Version:  Boost 1.58.0            |   Keywords:  then continuation
Resolution:                          |  is_ready
-------------------------------------+-------------------------------------

Comment (by viboes):

 Not tested yet


 {{{
   template<typename F, typename Rp>
   struct future_unwrap_shared_state: shared_state<Rp>
   {
     F wrapped;
     typename F::value_type unwrapped;
   public:
     explicit future_unwrap_shared_state(BOOST_THREAD_RV_REF(F) f)
     : wrapped(boost::move(f)) {
     }

     void launch_continuation(boost::unique_lock<boost::mutex>& lk,
 shared_ptr<shared_state_base> that)
     {
       if (! unwrapped.valid() )
       {
         if (wrapped.has_exception()) {
 this->mark_exceptional_finish_internal(wrapped.get_exception_ptr(), lk);
         } else {
           unwrapped = wrapped.get();
           if (unwrapped.valid())
           {
             lk.unlock();
             boost::unique_lock<boost::mutex>
 lk2(unwrapped.future_->mutex);
 unwrapped.future_->set_continuation_ptr(this->shared_from_this(), lk2);
           } else {
 this->mark_exceptional_finish_internal(boost::copy_exception(future_uninitialized()),
 lk);
           }
         }
       } else {
         if (unwrapped.has_exception()) {
 this->mark_exceptional_finish_internal(unwrapped.get_exception_ptr(), lk);
         } else {
           this->mark_finished_with_result_internal(unwrapped.get(), lk);
         }
       }
     }
   };
 }}}

-- 
Ticket URL: <https://svn.boost.org/trac/boost/ticket/11256#comment:18>
Boost C++ Libraries <http://www.boost.org/>
Boost provides free peer-reviewed portable C++ source libraries.