diff options
Diffstat (limited to 'boost/fiber/unbuffered_channel.hpp')
| -rw-r--r-- | boost/fiber/unbuffered_channel.hpp | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/boost/fiber/unbuffered_channel.hpp b/boost/fiber/unbuffered_channel.hpp index 2236d9e22f..dd08701707 100644 --- a/boost/fiber/unbuffered_channel.hpp +++ b/boost/fiber/unbuffered_channel.hpp @@ -384,13 +384,14 @@ public: while ( ! waiting_producers_.empty() ) { context * producer_ctx = & waiting_producers_.front(); waiting_producers_.pop_front(); - lk.unlock(); std::intptr_t expected = reinterpret_cast< std::intptr_t >( this); if ( producer_ctx->twstatus.compare_exchange_strong( expected, static_cast< std::intptr_t >( -1), std::memory_order_acq_rel) ) { + lk.unlock(); // notify context active_ctx->schedule( producer_ctx); break; } else if ( static_cast< std::intptr_t >( 0) == expected) { + lk.unlock(); // no timed-wait op. // notify context active_ctx->schedule( producer_ctx); @@ -430,13 +431,14 @@ public: while ( ! waiting_producers_.empty() ) { context * producer_ctx = & waiting_producers_.front(); waiting_producers_.pop_front(); - lk.unlock(); std::intptr_t expected = reinterpret_cast< std::intptr_t >( this); if ( producer_ctx->twstatus.compare_exchange_strong( expected, static_cast< std::intptr_t >( -1), std::memory_order_acq_rel) ) { + lk.unlock(); // notify context active_ctx->schedule( producer_ctx); break; } else if ( static_cast< std::intptr_t >( 0) == expected) { + lk.unlock(); // no timed-wait op. // notify context active_ctx->schedule( producer_ctx); @@ -489,13 +491,14 @@ public: while ( ! waiting_producers_.empty() ) { context * producer_ctx = & waiting_producers_.front(); waiting_producers_.pop_front(); - lk.unlock(); std::intptr_t expected = reinterpret_cast< std::intptr_t >( this); if ( producer_ctx->twstatus.compare_exchange_strong( expected, static_cast< std::intptr_t >( -1), std::memory_order_acq_rel) ) { + lk.unlock(); // notify context active_ctx->schedule( producer_ctx); break; } else if ( static_cast< std::intptr_t >( 0) == expected) { + lk.unlock(); // no timed-wait op. // notify context active_ctx->schedule( producer_ctx); |