Method __remove_callback_

include/stdexec/stop_token.hpp:371–412

  }

  inline void inplace_stop_source::__remove_callback_(STDEXEC::__stok::__inplace_stop_callback_base
                                                      * __callbk) const noexcept
  {
    auto __old_state = __lock_();

    if (__callbk->__prev_ptr_ != nullptr)
    {
      // Callback has not been executed yet.
      // Remove from the list.
      *__callbk->__prev_ptr_ = __callbk->__next_;
      if (__callbk->__next_ != nullptr)
      {
        __callbk->__next_->__prev_ptr_ = __callbk->__prev_ptr_;
      }
      __unlock_(__old_state);
    }
    else
    {
      auto __notifying_thread = __notifying_thread_;
      __unlock_(__old_state);

      // Callback has either already been executed or is
      // currently executing on another thread.
      if (std::this_thread::get_id() == __notifying_thread)
      {
        if (__callbk->__removed_during_callback_ != nullptr)
        {
          *__callbk->__removed_during_callback_ = true;
        }
      }
      else
      {
        // Concurrently executing on another thread.
        // Wait until the other thread finishes executing the callback.
        STDEXEC::__stok::__spin_wait __spin;
        while (!__callbk->__callback_completed_.load(STDEXEC::__std::memory_order_acquire))
        {
          __spin.__wait();
        }
      }
    }
  }

  struct get_stop_token_t : STDEXEC::__stok::__get_stop_token_t
  {