Changeset 14746 for branches/PushGP/HeuristicLab.PushGP/HeuristicLab.Problems.ProgramSynthesis/Push/Problem/PushProblem.cs

Timestamp:

03/11/17 20:07:13 (7 years ago)

Author:

pkimmesw

Message:

#2665 PooledPushProgram reduces memory usage and increases performance

File:

• branches/PushGP/HeuristicLab.PushGP/HeuristicLab.Problems.ProgramSynthesis/Push/Problem/PushProblem.cs (modified) (5 diffs)

branches/PushGP/HeuristicLab.PushGP/HeuristicLab.Problems.ProgramSynthesis/Push/Problem/PushProblem.cs

@@ -12 +12 @@
   using HeuristicLab.BenchmarkSuite;
   using HeuristicLab.Data;
+  using HeuristicLab.Problems.ProgramSynthesis.Push.Data.Pool;
+
   using Instances;
   using Interpreter;
@@ -26 +28 @@
     private readonly PushConfiguration config;
     private PushInterpreterPool pool;
+    private ManagedPoolProvider<PushProgram> pushProgramPoolProvider;
 
     public PushProblem() {
       config = new PushConfiguration();
       pool = new PushInterpreterPool(config);
+
+      pushProgramPoolProvider = new ManagedPoolProvider<PushProgram>(1024);
+      pushProgramPoolProvider.InitDummyPartition(() => new PushProgram());
 
       InitEvents();
@@ -56 +62 @@
       pool = new PushInterpreterPool(config);
       Instructions = config;
+
+      pushProgramPoolProvider = new ManagedPoolProvider<PushProgram>(1024);
+      pushProgramPoolProvider.InitDummyPartition(() => new PushProgram());
 
       InitEvents();
@@ -404 +413 @@
 
     public override double Evaluate(Individual individual, IRandom random) {
+      if (DataBounds[0, 1] <= 0) return default(double);
 
       var program = individual.PushProgram(config.EnabledExpressions as IReadOnlyList<string>);
-      var expandExpression = new PushProgram(program);
-      var results = new List<double>();
+      var result = 0d;
 
       using (var interpreter = pool.GetInstance(random)) {
         for (var i = DataBounds[0, 0]; i < DataBounds[0, 1]; i++) {
-          var example = this.DataDescriptor.Examples[i];
+          var example = DataDescriptor.Examples[i];
 
           interpreter.BooleanStack.Push(example.InputBoolean);
@@ -417 +426 @@
           interpreter.FloatStack.Push(example.InputFloat);
 
-          interpreter.Run(expandExpression);
-
-          var diff = GetDiff(example.OutputInt, interpreter.IntegerStack, this.DataDescriptor.WorstResult, LongDiffer) +
-                     GetDiff(example.OutputFloat, interpreter.FloatStack, this.DataDescriptor.WorstResult, DoubleDiffer) +
-                     GetDiff(example.OutputBoolean, interpreter.BooleanStack, this.DataDescriptor.WorstResult, BooleanDiffer);
-
-          results.Add(diff);
+          using (interpreter.PushProgramPool = pushProgramPoolProvider.CreatePool()) {
+            interpreter.Run(program);
+          }
+
+          result += GetDiff(example.OutputInt, interpreter.IntegerStack, DataDescriptor.WorstResult, LongDiffer)
+                  + GetDiff(example.OutputFloat, interpreter.FloatStack, DataDescriptor.WorstResult, DoubleDiffer)
+                  + GetDiff(example.OutputBoolean, interpreter.BooleanStack, DataDescriptor.WorstResult, BooleanDiffer);
+
           interpreter.Clear();
         }
       }
 
-      return results.Count == 0 ? 0d : results.Average();
+      return result / DataBounds[0, 1];
     }