TestWorkWithUseResult Class Reference

Inheritance diagram for TestWorkWithUseResult:

Collaboration diagram for TestWorkWithUseResult:

Public Member Functions
	TestWorkWithUseResult (std::shared_ptr< Horizon::System::RuntimeRoutineContext > parent_context)
bool	execute ()
void	set_previous_result (Horizon::System::Result< int > prev)
Horizon::System::Result< int >	get_previous_result ()
void	set_request (work_request _req)
work_request	get_request ()
void	set_result (ResultType res)
ResultType	get_result ()
bool	has_result ()
Public Member Functions inherited from Horizon::System::RuntimeRoutineContext::Work
	Work (std::shared_ptr< RuntimeRoutineContext > runtime_context)
	~Work ()
virtual bool	execute ()
std::shared_ptr< RuntimeRoutineContext >	get_runtime_context ()
void	set_runtime_context (std::shared_ptr< RuntimeRoutineContext > runtime_context)
MessageAgent &	get_message_agent ()
Public Member Functions inherited from Horizon::System::RuntimeContext::WorkContext
	WorkContext ()
virtual bool	execute ()
std::string	get_uuid_string ()

Public Attributes
Horizon::System::Result< int >	_prev_result
work_request	_request
ResultType	_result
Public Attributes inherited from Horizon::System::RuntimeContext::WorkContext
boost::uuids::uuid	_uuid

Private Types
typedef Horizon::System::Result< int >	ResultType

Additional Inherited Members
Protected Attributes inherited from Horizon::System::RuntimeRoutineContext::Work
std::weak_ptr< RuntimeRoutineContext >	_runtime_context
MessageAgent	_message_agent

Member Typedef Documentation

ResultType

typedef Horizon::System::Result<int> TestWorkWithUseResult::ResultType

private

Constructor & Destructor Documentation

TestWorkWithUseResult()

TestWorkWithUseResult::TestWorkWithUseResult ( std::shared_ptr< Horizon::System::RuntimeRoutineContext >  parent_context )

inline

    : Horizon::System::RuntimeRoutineContext::Work(parent_context), _result(0), _prev_result(0) { }

Member Function Documentation

execute()

bool TestWorkWithUseResult::execute ( )

inlinevirtual

Reimplemented from Horizon::System::RuntimeRoutineContext::Work.

                   { 
        using ResultType = Horizon::System::Result<int>;
        std::promise<ResultType> p;
        // Assuming this is the thread that will work on getting the result for either of the Kernel Components...
        // We can use a promise / future combination of techniques to derive the final result.
        std::thread t = std::thread([&]()
        { 
            std::cout << "Calculating..." << std::endl;
            p.set_value(ResultType(get_request().i * 20 + get_previous_result().get_one())); 
        });
        
        std::future<ResultType> f = p.get_future();
        get_runtime_context()->get_runtime_synchronization_mutex().lock();
        set_result(ResultType(f.get())); 
        get_runtime_context()->get_runtime_synchronization_mutex().unlock();
        t.join();
 
        return true;
    }

References get_previous_result(), get_request(), Horizon::System::RuntimeRoutineContext::Work::get_runtime_context(), and set_result().

Here is the call graph for this function:

get_previous_result()

Horizon::System::Result< int > TestWorkWithUseResult::get_previous_result ( )

inline

{ return _prev_result; }

References _prev_result.

Referenced by execute().

Here is the caller graph for this function:

get_request()

work_request TestWorkWithUseResult::get_request ( )

inline

{ return _request; }

References _request.

Referenced by execute().

Here is the caller graph for this function:

get_result()

ResultType TestWorkWithUseResult::get_result ( )

inline

{ return _result; }

References _result.

has_result()

bool TestWorkWithUseResult::has_result ( )

inline

                      {
        get_runtime_context()->get_runtime_synchronization_mutex().lock();
        bool result = _result.get_one() > 0;
        get_runtime_context()->get_runtime_synchronization_mutex().unlock();
        return result;  
    }

References _result, Horizon::System::ContextWithResult< T >::get_one(), and Horizon::System::RuntimeRoutineContext::Work::get_runtime_context().

Here is the call graph for this function:

set_previous_result()

void TestWorkWithUseResult::set_previous_result ( Horizon::System::Result< int >  prev )

inline

{ _prev_result = prev; }

References _prev_result.

set_request()

void TestWorkWithUseResult::set_request ( work_request  _req )

inline

{ _request = _req; }

References _request.

set_result()

void TestWorkWithUseResult::set_result ( ResultType  res )

inline

{ _result = res; }

References _result.

Referenced by execute().

Here is the caller graph for this function:

Member Data Documentation

_prev_result

Horizon::System::Result<int> TestWorkWithUseResult::_prev_result

Referenced by get_previous_result(), and set_previous_result().

_request

work_request TestWorkWithUseResult::_request

Referenced by get_request(), and set_request().

_result

ResultType TestWorkWithUseResult::_result

Referenced by get_result(), has_result(), and set_result().

---

The documentation for this class was generated from the following file:

• src/Tests/SystemRoutinesTest.cpp