Tbb.h

Go to the documentation of this file.

#pragma once
 
 
#include "objects/wrappers/PropagateConst.h"
#include "thread/Scheduler.h"
 
NAMESPACE_SPH_BEGIN
 
struct TbbData;
 
class Tbb : public IScheduler {
private:
    PropagateConst<AutoPtr<TbbData>> data;
 
    static SharedPtr<Tbb> globalInstance;
 
public:
    Tbb(const Size numThreads = 0, const Size granularity = 1000);
 
    ~Tbb();
 
    void setGranularity(const Size newGranularity);
 
    void setThreadCnt(const Size numThreads);
 
    virtual SharedPtr<ITask> submit(const Function<void()>& task) override;
 
    virtual Optional<Size> getThreadIdx() const override;
 
    virtual Size getThreadCnt() const override;
 
    virtual Size getRecommendedGranularity() const override;
 
    virtual void parallelFor(const Size from,
        const Size to,
        const Size granularity,
        const Function<void(Size n1, Size n2)>& functor) override;
 
    static SharedPtr<Tbb> getGlobalInstance();
};
 
 
NAMESPACE_SPH_END