task.hpp

Go to the documentation of this file.

//  Copyright (c) 2005-2008 Hartmut Kaiser
//  Copyright (c) 2005-2007 Andre Merzky (andre@merzky.net)
//  Copyright (c) 2005-2006 Stephan Hirmer (shirmer@cct.lsu.edu)
//  Copyright (c) 2007 Ole Weidner (oweidner@cct.lsu.edu)
// 
//  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 SAGA_TASK_HPP
#define SAGA_TASK_HPP

// include dependent spec sections
#include <saga/saga/base.hpp>
#include <saga/saga/util.hpp>
#include <saga/saga/task_base.hpp>
#include <saga/saga/object.hpp>

#include <saga/saga/uuid.hpp>
#include <saga/saga/detail/monitorable.hpp>
#include <saga/saga/detail/hold_any.hpp>

// suppress warnings about dependent classes not being exported from the dll
#if defined(BOOST_MSVC)
#pragma warning(push)
#pragma warning(disable: 4251 4231 4275 4660)
#endif

namespace saga 
{
    
    namespace metrics 
    {
        //  metric names for task
        
        char const* const task_state = "task.State";
        
    }
    
    class SAGA_EXPORT task 
    : public object,
    public detail::monitorable<task>,
    public task_base
    {
    private:

        friend struct saga::impl::runtime;
        friend struct detail::monitorable<task>;  // needs to access get_impl()
        
    protected:

        saga::impl::task_interface* get_task_if (void);
        saga::impl::task_interface const* get_task_if (void) const;
        typedef detail::monitorable<task> monitorable_base;
        
        explicit task (saga::impl::object* init);
        explicit task (saga::object const& o);
        task &operator= (saga::object const& o);
        
    public:
        typedef task_base::state state;
        
        explicit task (saga::task_base::state t = saga::task_base::New);
        
        ~task ();
        
        friend SAGA_EXPORT 
        bool operator== (task const & lhs, task const & rhs);
        
        void run(void);
        
        void cancel(void);
        
        bool wait(double timeout = -1.0);
        
        state get_state (void) const;
        
        void rethrow() const;
        
        saga::object get_object() const;
        
        template <typename Retval>
        Retval& get_result();
        
        template <typename Retval>
        Retval const& get_result() const;
        
        void get_result();
        void get_result() const;
    };
    
    namespace detail 
    {
        // some global functions to simplify the implementation of sync/async/task
        // versions of method calls
        

        SAGA_EXPORT inline saga::task run (saga::task t) 
        { 
            t.run(); 
            return t; 
        }
        
        SAGA_EXPORT inline saga::task wait (saga::task t, double timeout = -1.0) 
        { 
            t.wait (timeout); 
            return t; 
        }
        
        SAGA_EXPORT inline saga::task run_wait (saga::task t, double timeout = -1.0) 
        { 
            if (saga::task_base::New == t.get_state()) 
            {
                t.run(); 
                t.wait(timeout); 
            }
            return t; 
        }
        
        //  Helper function to extract task result from implementation without
        //  exposing any details
        SAGA_EXPORT detail::hold_any& get_task_result(saga::task t);
    } 
    
} // namespace saga

// re-enable warnings about dependent classes not being exported from the dll
#if defined(BOOST_MSVC)
#pragma warning(pop)
#endif

#endif // SAGA_TASK_HPP

---