ga/include/gas/parallelga.h

/********************************************************************************
 *  FARSA Genetic Algorithm Library                                             *
 *  Copyright (C) 2007-2009 Gianluca Massera <emmegian@yahoo.it>                *
 *                                                                              *
 *  This program is free software; you can redistribute it and/or modify        *
 *  it under the terms of the GNU General Public License as published by        *
 *  the Free Software Foundation; either version 2 of the License, or           *
 *  (at your option) any later version.                                         *
 *                                                                              *
 *  This program is distributed in the hope that it will be useful,             *
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of              *
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the               *
 *  GNU General Public License for more details.                                *
 *                                                                              *
 *  You should have received a copy of the GNU General Public License           *
 *  along with this program; if not, write to the Free Software                 *
 *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA  *
 ********************************************************************************/

#ifndef PARALLELGA_H
#define PARALLELGA_H

#include "gaconfig.h"
#include "core/geneticalgo.h"
#include <QList>
#include <QFuture>

namespace farsa {

class Evaluation;
class Reproduction;

class FARSA_GA_API ParallelGA : public GeneticAlgo {
public:
    ParallelGA();
    virtual ~ParallelGA();
    void setNumThreads( int numThreads );
    int numThreads();
    void setEvaluation( Evaluation* fitfunc );
    virtual Evaluation* evaluationPrototype();
    virtual QVector<Evaluation*> evaluationPool();
    void setReproduction( Reproduction* reproduct );
    Reproduction* reproduction();
    virtual void initialize();
    virtual void gaStep();
    virtual void finalize();

    virtual void skipEvaluation();

    virtual void configure( ConfigurationParameters& params, QString prefix );
    virtual void save( ConfigurationParameters& params, QString prefix );
    static void describe( QString type );

protected:
    Evaluation* fitfunc;
    Reproduction* reprod;
    typedef enum { initEvaluation, evaluating, nextGeneration_pass1, nextGeneration_pass2, endEvolution } GAPhases;
    GAPhases currPhase;
    bool isInitialized;
    bool isFinalized;

private:
    bool nextGeneration;

    class evaluationThread {
    public:
        //--- Constructor
        evaluationThread( Evaluation* eProto );
        //--- Destructor
        ~evaluationThread();
        //--- evaluator used by this object
        Evaluation* eval;
        //--- evaluating genoma
        int id;
        //--- run a step of evaluation
        void runStep();
        //--- sequence of Genoma to evaluate
        QVector<int> sequence;
        //--- actual id inside sequence in evaluating
        int idSeq;
    };

    QList<evaluationThread*> evalThreads;
    int numThreadv;
    static void runStepWrapper( ParallelGA::evaluationThread* e );
    QFuture<void>* future;
};

} // end namespace farsa

#endif