task.h

Go to the documentation of this file.

#ifndef TASK_H
#define TASK_H

#include "src/environment.h"
#include <vector>

namespace skepu
{


class Task
{
    public:
    // return tag id
    virtual void run_async() = 0;
    
    // default implementation given, if not overridden
    virtual void wait_for_completion(unsigned int tagId)
    {
        starpu_tag_wait(tagId);
    }
    
    // default implementation for those Tasks that dont return a value.
    virtual void *get_result()
    {
        return 0;
    }

};


// Macros as they can yield better performance than functions, if not inlined.
  
#define getIsFormCall() Environment<int>::getInstance()->m_isFarmCall

#define setIsFormCall(arg) Environment<int>::getInstance()->m_isFarmCall = arg

#define getUseTagId() Environment<int>::getInstance()->m_useTagIds

#define setUseTagId(arg) Environment<int>::getInstance()->m_useTagIds = arg

#define setFarmNoWait(arg) Environment<int>::getInstance()->m_useTagIds = arg

// to reset TagIds, for each new farm invocation or if you want to reset it after some time.
#define resetTagIds() Environment<int>::getInstance()->m_tagIds.clear()

// to return TagIds vector
#define getTagIds() Environment<int>::getInstance()->m_tagIds

}

#endif