TestWork Class Reference

Inheritance diagram for TestWork:

Collaboration diagram for TestWork:

Public Member Functions
	TestWork (std::shared_ptr< Horizon::System::RuntimeRoutineContext > parent_context)
bool	execute ()
void	set_result (ResultType res)
ResultType	get_result ()
void	set_request (work_request _req)
work_request	get_request ()
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
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> TestWork::ResultType

private

Constructor & Destructor Documentation

TestWork()

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

inline

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

Member Function Documentation

execute()

bool TestWork::execute ( )

inlinevirtual

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

                   { 
        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)); 
        });
 
        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_request(), Horizon::System::RuntimeRoutineContext::Work::get_runtime_context(), and set_result().

Here is the call graph for this function:

get_request()

work_request TestWork::get_request ( )

inline

{ return _request; }

References _request.

Referenced by execute().

Here is the caller graph for this function:

get_result()

ResultType TestWork::get_result ( )

inline

{ return _result; }

References _result.

has_result()

bool TestWork::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_request()

void TestWork::set_request ( work_request  _req )

inline

{ _request = _req; }

References _request.

set_result()

void TestWork::set_result ( ResultType  res )

inline

{ _result = res; }

References _result.

Referenced by execute().

Here is the caller graph for this function:

Member Data Documentation

_request

work_request TestWork::_request

Referenced by get_request(), and set_request().

_result

ResultType TestWork::_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