peo

git-svn-id: svn://scm.gforge.inria.fr/svnroot/paradiseo@1118 331e1502-861f-0410-8da2-ba01fb791d7f

trunk/paradiseo-peo/tutorial/Lesson6/CMakeLists.txt

@@ -0,0 +1,72 @@
+
+######################################################################################
+### 0) Set the compiler and define targets to easily run the lessons
+######################################################################################
+
+SET (CMAKE_CXX_COMPILER mpicxx)
+
+ADD_CUSTOM_TARGET(install DEPENDS ${ParadisEO-PEO_SOURCE_DIR}/tutorial/Lesson6/param ${ParadisEO-PEO_SOURCE_DIR}/tutorial/Lesson6/schema.xml)
+
+ADD_CUSTOM_COMMAND(
+    TARGET install
+    POST_BUILD
+    COMMAND ${CMAKE_COMMAND}
+    ARGS -E copy_if_different
+      ${ParadisEO-PEO_SOURCE_DIR}/tutorial/Lesson6/param
+      ${ParadisEO-PEO_BINARY_DIR}/tutorial/Lesson6)
+ADD_CUSTOM_COMMAND(
+    TARGET install
+    POST_BUILD
+    COMMAND ${CMAKE_COMMAND}
+    ARGS -E copy_if_different
+      ${ParadisEO-PEO_SOURCE_DIR}/tutorial/Lesson6/schema.xml
+      ${ParadisEO-PEO_BINARY_DIR}/tutorial/Lesson6)
+
+######################################################################################
+
+
+######################################################################################
+### 1) Include the sources
+######################################################################################
+
+INCLUDE_DIRECTORIES(${EO_SRC_DIR}/src ${MOEO_SRC_DIR}/src ${MO_SRC_DIR}/src ${ParadisEO-PEO_SOURCE_DIR}/src ${TSP_SRC_DIR})
+
+######################################################################################
+
+
+######################################################################################
+### 2) Specify where CMake can find the libraries
+######################################################################################
+
+LINK_DIRECTORIES(${EO_BIN_DIR}/lib ${ParadisEO-PEO_BINARY_DIR}/lib ${TSP_BINARY_DIR}/lib)
+
+######################################################################################
+
+
+######################################################################################
+### 3) Define your target(s): just an executable here
+######################################################################################
+
+ADD_EXECUTABLE(ea main.cpp)
+ADD_DEPENDENCIES(ea peo rmc_mpi)
+
+######################################################################################
+
+
+######################################################################################
+### 4) Optionnal: define properties
+######################################################################################
+
+SET(Lesson6_VERSION ${GLOBAL_VERSION})
+SET_TARGET_PROPERTIES(ea PROPERTIES VERSION "${Lesson6_VERSION}")
+######################################################################################
+
+
+######################################################################################
+### 5) Link the librairies
+######################################################################################
+
+TARGET_LINK_LIBRARIES(ea ${XML2_LIBS} tsp peo rmc_mpi eo eoutils peo)
+
+######################################################################################
+

trunk/paradiseo-peo/tutorial/Lesson6/main.cpp

@@ -0,0 +1,122 @@
+#include <peo>
+
+#include <peoAsyncDataTransfer.h>
+#include <peoSyncDataTransfer.h>
+
+#include "route.h"
+#include "route_init.h"
+#include "route_eval.h"
+#include "order_xover.h"
+#include "city_swap.h"
+#include "param.h"
+
+
+
+#define POP_SIZE 10
+#define NUM_GEN 100
+#define CROSS_RATE 1.0
+#define MUT_RATE 0.01
+
+
+struct CoSearch 
+{
+
+  CoSearch( 
+	   eoPop< Route >& A, eoPop< Route >& B, 
+	   peoAsyncDataTransfer& asyncTransferA, peoAsyncDataTransfer& asyncTransferB 
+	    )
+    : transferA( A ), transferB( B ),
+      asyncDataTransferA( asyncTransferA ), asyncDataTransferB( asyncTransferB ) {
+  }
+  
+  void operator()() {
+
+    for ( unsigned int index = 0; index < 100; index++ ) {
+
+      asyncDataTransferA();
+      asyncDataTransferB();
+
+      eoPop< Route > intermed;
+      intermed = transferA;
+      transferA = transferB;
+      transferB = intermed;
+    }
+  }
+
+  eoPop< Route >& transferA;
+  eoPop< Route >& transferB;
+  
+  peoAsyncDataTransfer& asyncDataTransferA;
+  peoAsyncDataTransfer& asyncDataTransferB;
+};
+
+
+struct PushBackAggregation {
+
+  void operator()( eoPop< Route >& A, eoPop< Route >& B ) {
+
+    for ( unsigned int index = 0; index < B.size(); index++ ) {
+
+      A.push_back( B[ index ] );
+    }
+  }
+};
+
+int main( int __argc, char** __argv ) {
+
+  peo :: init( __argc, __argv );
+
+  loadParameters( __argc, __argv );
+  
+  RouteInit route_init;	
+  RouteEval full_eval;	
+  OrderXover crossover;
+  CitySwap mutation;	
+  eoPop< Route > population( POP_SIZE, route_init );	
+  eoGenContinue< Route > eaCont( NUM_GEN );		
+  eoCheckPoint< Route > eaCheckpointContinue( eaCont );
+  eoRankingSelect< Route > selectionStrategy;	
+  eoSelectNumber< Route > eaSelect( selectionStrategy, POP_SIZE );
+  eoSGATransform< Route > transformA( crossover, CROSS_RATE, mutation, MUT_RATE );
+  eoPlusReplacement< Route > eaReplace;			
+  RingTopology ring;
+  eoPlusReplacement< Route > transferReplace;			
+  peoAsyncDataTransfer asyncEAEndPoint( population, population, ring, transferReplace );
+  eaCheckpointContinue.add( asyncEAEndPoint );
+  eoEasyEA< Route > eaAlg( eaCheckpointContinue, full_eval, eaSelect, transformA, eaReplace );
+  peoWrapper paraEAAlg( eaAlg, population );
+  asyncEAEndPoint.setOwner( paraEAAlg );
+
+  eoPop< Route > populationB( POP_SIZE, route_init );	
+  eoGenContinue< Route > eaContB( NUM_GEN );		
+  eoCheckPoint< Route > eaCheckpointContinueB( eaContB );	
+  eoRankingSelect< Route > selectionStrategyB;
+  eoSelectNumber< Route > eaSelectB( selectionStrategyB, POP_SIZE );
+  RingTopology ringB;
+  eoPlusReplacement< Route > transferReplaceB;			
+  peoAsyncDataTransfer asyncEAEndPointB( populationB, populationB, ringB, transferReplaceB );
+  eaCheckpointContinueB.add( asyncEAEndPointB );
+  eoSGATransform< Route > transformB	( crossover, CROSS_RATE, mutation, MUT_RATE );
+  eoEasyEA< Route > eaAlgB( eaCheckpointContinueB, full_eval, eaSelectB, transformB, eaReplace );
+  peoWrapper paraEAAlgB( eaAlgB, populationB );
+  asyncEAEndPointB.setOwner( paraEAAlgB );
+
+
+  eoPop< Route > A, B;
+  PushBackAggregation pushBackA, pushBackB;
+
+  peoAsyncDataTransfer coSearchEndPointA( A, A, ring, pushBackA );
+  peoAsyncDataTransfer coSearchEndPointB( B, B, ringB, pushBackB );
+  
+  CoSearch coSearch( A, B, coSearchEndPointA, coSearchEndPointB );
+  peoWrapper paraCoSearch( coSearch );
+  coSearchEndPointA.setOwner( paraCoSearch );
+  coSearchEndPointB.setOwner( paraCoSearch );
+
+
+
+  peo::run();
+  peo::finalize();
+
+  return 0;
+}

trunk/paradiseo-peo/tutorial/Lesson6/param

@@ -0,0 +1,15 @@
+######    Param                   ######
+--maxGen=1                             
+--select=0.8
+
+## miscallenous parameters
+
+--debug=false
+
+## deployment schema
+
+--schema=schema.xml
+
+## parameters
+
+--inst=../examples/tsp/benchs/eil101.tsp

trunk/paradiseo-peo/tutorial/Lesson6/schema.xml

@@ -0,0 +1,19 @@
+<?xml version="1.0"?>
+
+<schema>
+	<group scheduler="0">
+		<node name="0" num_workers="0">
+		</node>
+		<node name="1" num_workers="0">
+		<runner>1</runner>
+		</node>
+		<node name="2" num_workers="1">
+		<runner>2</runner>
+		</node>
+		<node name="3" num_workers="1">
+		<runner>3</runner>
+		</node>
+		
+	</group>
+</schema>
+