Lely core libraries
2.3.4
|
Go to the documentation of this file.
24 #ifndef LELY_EV_FIBER_EXEC_HPP_
25 #define LELY_EV_FIBER_EXEC_HPP_
65 ::std::size_t stack_size = 0, ::std::size_t max_unused = 0) {
68 util::throw_errc(
"FiberThread");
94 ::std::size_t max_unused,
bool& already) {
97 if (result == -1) util::throw_errc(
"FiberThread");
98 already = result != 0;
120 if (!exec_) ::lely::util::throw_errc(
"FiberExecutor");
126 other.exec_ =
nullptr;
134 swap(exec_, other.exec_);
149 template <
class T,
class E>
169 throw_fiber_error(
const char* what_arg,
int ev) {
174 util::throw_errc(what_arg);
179 throw ::std::system_error(
183 throw ::std::system_error(
220 detail::throw_fiber_error(
"try_lock", ev);
253 detail::throw_fiber_error(
"FiberRecursiveMutex", ev);
262 ::lely::util::throw_errc(
"FiberConditionVariable");
289 wait(std::unique_lock<FiberMutex>& lock) {
295 template <
class Predicate>
297 wait(std::unique_lock<FiberMutex>& lock, Predicate pred) {
298 while (!pred())
wait(lock);
308 #endif // !LELY_EV_FIBER_EXEC_HPP_
void ev_fiber_exec_destroy(ev_exec_t *exec)
Destroys a fiber executor.
void ev_fiber_thrd_fini(void)
Finalizes the calling thread and prevents further use by fiber executors.
FiberThread(FiberFlag flags=static_cast< FiberFlag >(0), ::std::size_t stack_size=0, ::std::size_t max_unused=0)
Initializes the calling thread for use by fiber executors, if it was not already initialized.
Convenience class providing a RAII-style mechanism to ensure the calling thread can be used by fiber ...
@ ev_fiber_mtx_plain
A fiber mutex type that supports neither timeout nor recursive locking.
void notify_one() noexcept
ev_exec_t * ev_fiber_exec_create(ev_exec_t *inner_exec)
Creates a fiber executor.
@ ev_fiber_mtx_recursive
A fiber mutex type that supports recursive locking.
A recursive mutex suitable for use in fibers.
FiberFlag
Specifies which properties of the calling environment are saved or restored by a fiber when it is sus...
int ev_fiber_cnd_wait(ev_fiber_cnd_t *cond, ev_fiber_mtx_t *mtx)
Atomically unlocks the fiber mutex at mtx and endeavors to block until the fiber condition variable a...
void ev_fiber_cnd_destroy(ev_fiber_cnd_t *cond)
Releases all resources used by the fiber condition variable at cond.
void ev_fiber_mtx_destroy(ev_fiber_mtx_t *mtx)
Releases any resources used by the fiber mutex at mtx.
FiberThread(FiberFlag flags, ::std::size_t stack_size, ::std::size_t max_unused, bool &already)
Initializes the calling thread for use by fiber executors, if it was not already initialized.
int ev_fiber_mtx_trylock(ev_fiber_mtx_t *mtx)
Endeavors to lock the fiber mutex at mtx.
int ev_fiber_thrd_init(int flags, size_t stack_size, size_t max_unused)
Initializes the calling thread for use by fiber executors.
A condition variable suitable for use in fibers.
An abstract task executor. This class is a wrapper around #ev_exec_t*.
int ev_fiber_cnd_signal(ev_fiber_cnd_t *cond)
Unblocks one of the fibers that are blocked on the fiber condition variable at cond at the time of th...
@ ev_fiber_error
Indicates that the requested operation failed.
void wait(std::unique_lock< FiberMutex > &lock)
void ev_fiber_await(ev_future_t *future)
Suspends a currently running fiber until the specified future becomes ready (or is cancelled).
~FiberThread()
Finalizes the calling thread and prevents further use by fiber executors, unless another instance of ...
A plain mutex suitable for use in fibers.
A synchronization primitive (similar to the standard C11 mutex) that can be used to protect shared da...
@ ev_fiber_success
Indicates that the requested operation succeeded.
The base class for mutexes suitable for use in fibers.
void fiber_await(Future< T, E > f) noexcept
@ ev_fiber_nomem
Indicates that the requested operation failed because it was unable to allocate memory.
void wait(std::unique_lock< FiberMutex > &lock, Predicate pred)
int ev_fiber_mtx_init(ev_fiber_mtx_t *mtx, int type)
Creates a fiber mutex object with properties indicated by type, which must have one of the four value...
A synchronization primitive (similar to the standard C11 condition variable) that can be used to bloc...
@ ev_fiber_timedout
Indicates that the time specified in the call was reached without acquiring the requested resource.
void notify_all() noexcept
ev_exec_t * ev_fiber_exec_get_inner_exec(const ev_exec_t *exec)
Returns a pointer to the inner executor of a fiber executor.
::std::error_code make_error_code(SdoErrc e) noexcept
Creates an error code corresponding to an SDO abort code.
void fiber_yield() noexcept
Yields a currently running fiber.
FiberExecutor(Executor inner_exec)
Executor get_inner_executor() const noexcept
int ev_fiber_cnd_init(ev_fiber_cnd_t *cond)
Creates a fiber condition variable.
@ ev_fiber_busy
Indicates that the requested operation failed because a resource requested by a test and return funct...
int ev_fiber_cnd_broadcast(ev_fiber_cnd_t *cond)
Unblocks all of the fibers that are blocked on the fiber condition variable at cond at the time of th...
int ev_fiber_mtx_unlock(ev_fiber_mtx_t *mtx)
Unlocks the fiber mutex at mtx.
int ev_fiber_mtx_lock(ev_fiber_mtx_t *mtx)
Suspends the currently running fiber until it locks the fiber mutex at mtx.