Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Stackless coroutines now can refer to themselves (through get_self() …
…and friends)
- Loading branch information
Showing
9 changed files
with
345 additions
and
136 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
120 changes: 120 additions & 0 deletions
120
libs/coroutines/include/hpx/coroutines/detail/coroutine_stackful_self.hpp
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,120 @@ | ||
| // Copyright (c) 2019 Hartmut Kaiser | ||
| // | ||
| // SPDX-License-Identifier: BSL-1.0 | ||
| // Distributed under the Boost Software License, Version 1.0. (See accompanying | ||
| // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) | ||
|
|
||
| #ifndef HPX_RUNTIME_THREADS_COROUTINES_DETAIL_STACKFUL_SELF_HPP | ||
| #define HPX_RUNTIME_THREADS_COROUTINES_DETAIL_STACKFUL_SELF_HPP | ||
|
|
||
| #include <hpx/config.hpp> | ||
| #include <hpx/assertion.hpp> | ||
| #include <hpx/coroutines/detail/coroutine_impl.hpp> | ||
| #include <hpx/coroutines/detail/coroutine_self.hpp> | ||
| #include <hpx/coroutines/thread_enums.hpp> | ||
| #include <hpx/coroutines/thread_id_type.hpp> | ||
| #include <hpx/functional/function.hpp> | ||
|
|
||
| #include <cstddef> | ||
| #include <exception> | ||
| #include <limits> | ||
| #include <utility> | ||
|
|
||
| namespace hpx { namespace threads { namespace coroutines { namespace detail { | ||
|
|
||
| class coroutine_stackful_self : public coroutine_self | ||
| { | ||
| public: | ||
| explicit coroutine_stackful_self( | ||
| impl_type* pimpl, coroutine_self* next_self = nullptr) | ||
| : coroutine_self(next_self) | ||
| , pimpl_(pimpl) | ||
| { | ||
| } | ||
|
|
||
| arg_type yield_impl(result_type arg) override | ||
| { | ||
| HPX_ASSERT(pimpl_); | ||
|
|
||
| this->pimpl_->bind_result(arg); | ||
|
|
||
| { | ||
| reset_self_on_exit on_exit(this); | ||
| this->pimpl_->yield(); | ||
| } | ||
|
|
||
| return *pimpl_->args(); | ||
| } | ||
|
|
||
| thread_id_type get_thread_id() const override | ||
| { | ||
| HPX_ASSERT(pimpl_); | ||
| return pimpl_->get_thread_id(); | ||
| } | ||
|
|
||
| std::size_t get_thread_phase() const override | ||
| { | ||
| #if defined(HPX_HAVE_THREAD_PHASE_INFORMATION) | ||
| HPX_ASSERT(pimpl_); | ||
| return pimpl_->get_thread_phase(); | ||
| #else | ||
| return 0; | ||
| #endif | ||
| } | ||
|
|
||
| std::ptrdiff_t get_available_stack_space() override | ||
| { | ||
| #if defined(HPX_HAVE_THREADS_GET_STACK_POINTER) | ||
| return pimpl_->get_available_stack_space(); | ||
| #else | ||
| return (std::numeric_limits<std::ptrdiff_t>::max)(); | ||
| #endif | ||
| } | ||
|
|
||
| std::size_t get_thread_data() const override | ||
| { | ||
| HPX_ASSERT(pimpl_); | ||
| return pimpl_->get_thread_data(); | ||
| } | ||
| std::size_t set_thread_data(std::size_t data) override | ||
| { | ||
| HPX_ASSERT(pimpl_); | ||
| return pimpl_->set_thread_data(data); | ||
| } | ||
|
|
||
| tss_storage* get_thread_tss_data() override | ||
| { | ||
| #if defined(HPX_HAVE_THREAD_LOCAL_STORAGE) | ||
| HPX_ASSERT(pimpl_); | ||
| return pimpl_->get_thread_tss_data(false); | ||
| #else | ||
| return nullptr; | ||
| #endif | ||
| } | ||
|
|
||
| tss_storage* get_or_create_thread_tss_data() override | ||
| { | ||
| #if defined(HPX_HAVE_THREAD_LOCAL_STORAGE) | ||
| HPX_ASSERT(pimpl_); | ||
| return pimpl_->get_thread_tss_data(true); | ||
| #else | ||
| return nullptr; | ||
| #endif | ||
| } | ||
|
|
||
| std::size_t& get_continuation_recursion_count() override | ||
| { | ||
| HPX_ASSERT(pimpl_); | ||
| return pimpl_->get_continuation_recursion_count(); | ||
| } | ||
|
|
||
| private: | ||
| coroutine_impl* get_impl() override | ||
| { | ||
| return pimpl_; | ||
| } | ||
| coroutine_impl* pimpl_; | ||
| }; | ||
| }}}} // namespace hpx::threads::coroutines::detail | ||
|
|
||
| #endif /*HPX_RUNTIME_THREADS_COROUTINES_DETAIL_SELF_HPP*/ |
Oops, something went wrong.