2020-02-04 11:06:23 -08:00
|
|
|
// Copyright 2020 yuzu Emulator Project
|
|
|
|
// Licensed under GPLv2 or any later version
|
|
|
|
// Refer to the license.txt file included.
|
|
|
|
|
|
|
|
#pragma once
|
|
|
|
|
|
|
|
#include <functional>
|
|
|
|
#include <memory>
|
|
|
|
|
|
|
|
#include "common/common_types.h"
|
|
|
|
#include "common/spin_lock.h"
|
|
|
|
|
2020-02-10 10:21:23 -08:00
|
|
|
#if !defined(_WIN32) && !defined(WIN32)
|
2020-02-05 10:13:16 -08:00
|
|
|
namespace boost::context::detail {
|
2020-02-10 09:33:13 -08:00
|
|
|
struct transfer_t;
|
2020-02-05 10:13:16 -08:00
|
|
|
}
|
|
|
|
#endif
|
|
|
|
|
2020-02-04 11:06:23 -08:00
|
|
|
namespace Common {
|
|
|
|
|
2020-02-05 11:48:20 -08:00
|
|
|
/**
|
|
|
|
* Fiber class
|
|
|
|
* a fiber is a userspace thread with it's own context. They can be used to
|
|
|
|
* implement coroutines, emulated threading systems and certain asynchronous
|
|
|
|
* patterns.
|
|
|
|
*
|
|
|
|
* This class implements fibers at a low level, thus allowing greater freedom
|
|
|
|
* to implement such patterns. This fiber class is 'threadsafe' only one fiber
|
|
|
|
* can be running at a time and threads will be locked while trying to yield to
|
|
|
|
* a running fiber until it yields. WARNING exchanging two running fibers between
|
2020-03-06 07:24:08 -08:00
|
|
|
* threads will cause a deadlock. In order to prevent a deadlock, each thread should
|
|
|
|
* have an intermediary fiber, you switch to the intermediary fiber of the current
|
|
|
|
* thread and then from it switch to the expected fiber. This way you can exchange
|
|
|
|
* 2 fibers within 2 different threads.
|
2020-02-05 11:48:20 -08:00
|
|
|
*/
|
2020-02-04 11:06:23 -08:00
|
|
|
class Fiber {
|
|
|
|
public:
|
|
|
|
Fiber(std::function<void(void*)>&& entry_point_func, void* start_parameter);
|
|
|
|
~Fiber();
|
|
|
|
|
|
|
|
Fiber(const Fiber&) = delete;
|
|
|
|
Fiber& operator=(const Fiber&) = delete;
|
|
|
|
|
2020-11-04 17:41:16 -08:00
|
|
|
Fiber(Fiber&&) = delete;
|
|
|
|
Fiber& operator=(Fiber&&) = delete;
|
2020-02-04 11:06:23 -08:00
|
|
|
|
|
|
|
/// Yields control from Fiber 'from' to Fiber 'to'
|
|
|
|
/// Fiber 'from' must be the currently running fiber.
|
2020-10-27 21:42:41 -07:00
|
|
|
static void YieldTo(std::shared_ptr<Fiber> from, std::shared_ptr<Fiber> to);
|
2020-08-14 06:38:45 -07:00
|
|
|
[[nodiscard]] static std::shared_ptr<Fiber> ThreadToFiber();
|
2020-02-04 11:06:23 -08:00
|
|
|
|
2020-10-30 12:02:02 -07:00
|
|
|
void SetRewindPoint(std::function<void(void*)>&& rewind_func, void* rewind_param);
|
2020-02-27 12:32:47 -08:00
|
|
|
|
|
|
|
void Rewind();
|
|
|
|
|
2020-02-04 11:06:23 -08:00
|
|
|
/// Only call from main thread's fiber
|
|
|
|
void Exit();
|
|
|
|
|
|
|
|
/// Changes the start parameter of the fiber. Has no effect if the fiber already started
|
|
|
|
void SetStartParameter(void* new_parameter) {
|
|
|
|
start_parameter = new_parameter;
|
|
|
|
}
|
|
|
|
|
|
|
|
private:
|
|
|
|
Fiber();
|
|
|
|
|
2020-02-10 10:21:23 -08:00
|
|
|
#if defined(_WIN32) || defined(WIN32)
|
2020-05-13 10:49:36 -07:00
|
|
|
void OnRewind();
|
|
|
|
void Start();
|
2020-02-05 10:13:16 -08:00
|
|
|
static void FiberStartFunc(void* fiber_parameter);
|
2020-02-27 12:32:47 -08:00
|
|
|
static void RewindStartFunc(void* fiber_parameter);
|
2020-02-05 10:13:16 -08:00
|
|
|
#else
|
2020-05-13 10:49:36 -07:00
|
|
|
void OnRewind(boost::context::detail::transfer_t& transfer);
|
|
|
|
void Start(boost::context::detail::transfer_t& transfer);
|
2020-02-05 10:13:16 -08:00
|
|
|
static void FiberStartFunc(boost::context::detail::transfer_t transfer);
|
2020-04-01 06:19:10 -07:00
|
|
|
static void RewindStartFunc(boost::context::detail::transfer_t transfer);
|
2020-02-05 10:13:16 -08:00
|
|
|
#endif
|
|
|
|
|
2020-02-04 11:06:23 -08:00
|
|
|
struct FiberImpl;
|
|
|
|
|
2020-02-10 10:45:08 -08:00
|
|
|
SpinLock guard{};
|
2020-05-13 10:49:36 -07:00
|
|
|
std::function<void(void*)> entry_point;
|
|
|
|
std::function<void(void*)> rewind_point;
|
2020-02-27 12:32:47 -08:00
|
|
|
void* rewind_parameter{};
|
2020-02-10 10:45:08 -08:00
|
|
|
void* start_parameter{};
|
2020-05-13 10:49:36 -07:00
|
|
|
std::shared_ptr<Fiber> previous_fiber;
|
2020-02-04 11:06:23 -08:00
|
|
|
std::unique_ptr<FiberImpl> impl;
|
|
|
|
bool is_thread_fiber{};
|
2020-05-13 10:49:36 -07:00
|
|
|
bool released{};
|
2020-02-04 11:06:23 -08:00
|
|
|
};
|
|
|
|
|
|
|
|
} // namespace Common
|