ComputeThread.h

Go to the documentation of this file.

#pragma once

#include <OpenThreads/Thread>
#include "ComputeStrategy.h"
#include "Utils.h"
#include <random>

namespace APDYNAMICART
{

struct InitSettings 
{
    IComputeStrategyPtr strategy;
    Parameters params;
    float size;
    int settleIterations;
    int iterationCount;
    int interpolationSteps;
    bool randomRun;
};

class ComputeThread : public OpenThreads::Thread, public osg::Referenced
{

public:
    ComputeThread();
    virtual void run();

    bool isTooSmall( int i, int iter );

    virtual int cancel();

    void init(const InitSettings& settings);
    bool getData(osg::Vec3Array* points, osg::Vec4Array* colors, Limits& limits,  Parameters& params);
    void addPoint( osg::Vec3 point );
    void setColor( osg::Vec4 color, int index );
    void interpolatePoints();

protected:
    bool _dirty;
    bool _done;

    OpenThreads::Mutex _mutex;
    Vec3ArrayPtr _points;
    Vec4ArrayPtr _colors;
    Limits _lim;
    InitSettings _conf;
    static std::tr1::mt19937 eng;
    osg::Vec3 _initPoint;
private:
    bool isDiverging( osg::Vec3 &point );
    void createRandomParameters();
    void computeColors();
    void computePoints();
};

typedef osg::ref_ptr<ComputeThread> ComputeThreadPtr;

}