Changeset 14747 for branches/PushGP/HeuristicLab.PushGP/HeuristicLab.Problems.ProgramSynthesis/Push/Interpreter

Timestamp:

03/12/17 13:16:56 (8 years ago)

Author:

pkimmesw

Message:

#2665 fixed enable/disable issue for single instruction in selection view

Location:

branches/PushGP/HeuristicLab.PushGP/HeuristicLab.Problems.ProgramSynthesis/Push/Interpreter

Files:

• PooledPushInterpreter.cs (modified) (2 diffs)
• PushInterpreter.cs (modified) (5 diffs)
• PushInterpreterPool.cs (modified) (1 diff)

branches/PushGP/HeuristicLab.PushGP/HeuristicLab.Problems.ProgramSynthesis/Push/Interpreter/PooledPushInterpreter.cs

@@ -4 +4 @@
   using HeuristicLab.Core;
   using HeuristicLab.Problems.ProgramSynthesis.Push.Configuration;
+  using HeuristicLab.Problems.ProgramSynthesis.Push.Data.Pool;
+  using HeuristicLab.Problems.ProgramSynthesis.Push.Expressions;
 
   public class PooledPushInterpreter : PushInterpreter, IDisposable {
@@ -9 +11 @@
     private readonly PushInterpreterPool pool;
 
-    public PooledPushInterpreter(PushInterpreterPool pool, PushConfiguration config, IRandom random = null)
-      : base(config, random) {
+    public PooledPushInterpreter(PushInterpreterPool pool, PushConfiguration config, ManagedPoolProvider<PushProgram> pushProgramPoolProvider, IRandom random = null)
+      : base(config, random, pushProgramPoolProvider) {
       this.pool = pool;
     }

branches/PushGP/HeuristicLab.PushGP/HeuristicLab.Problems.ProgramSynthesis/Push/Interpreter/PushInterpreter.cs

@@ -19 +19 @@
     private Task currentTask;
 
-    public PushInterpreter(IReadonlyPushConfiguration config = null, IRandom random = null) {
+    public PushInterpreter(IReadonlyPushConfiguration config = null, IRandom random = null, ManagedPoolProvider<PushProgram> pushProgramPoolProvider = null) {
       Random = random ?? new FastRandom();
 
@@ -45 +45 @@
 
       CustomExpressions = new Dictionary<string, Expression>();
+
+      PushProgramPoolProvider = pushProgramPoolProvider ?? new ManagedPoolProvider<PushProgram>(1024);
+
+      if (pushProgramPoolProvider == null)
+      {
+        PushProgramPoolProvider.InitDummyPartition(() => new PushProgram());
+      }
     }
 
@@ -86 +93 @@
     }
 
-    public IManagedPool<PushProgram> PushProgramPool { get; set; }
+    private readonly ManagedPoolProvider<PushProgram> PushProgramPoolProvider;
+    public IManagedPool<PushProgram> PushProgramPool { get; private set; }
 
     public IReadonlyPushConfiguration Configuration { get; protected set; }
@@ -127 +135 @@
 
     public void Run(Expression program, bool stepwise = false) {
-      IsPaused = stepwise;
-
-      /* Push top expression so the loop is able to enter
-       * If the top expression is a single statement then the loop has nothing to do
-       * Otherwise the expand expression will be evaluated and pushes code onto the EXEC stack */
-      ExecStack.Push(program);
-
-      if (Configuration.TopLevelPushCode) CodeStack.Insert(0, program);
-
-      // run top expression
-      DoStep();
-
-      Interpret();
+      using (PushProgramPool = PushProgramPoolProvider.CreatePool()) {
+        IsPaused = stepwise;
+
+        /* Push top expression so the loop is able to enter
+         * If the top expression is a single statement then the loop has nothing to do
+         * Otherwise the expand expression will be evaluated and pushes code onto the EXEC stack */
+        ExecStack.Push(program);
+
+        if (Configuration.TopLevelPushCode) CodeStack.Insert(0, program);
+
+        // run top expression
+        DoStep();
+
+        Interpret();
+      }
     }
 
@@ -146 +156 @@
 
       IsAborted = true;
+
+      if (PushProgramPool != null) PushProgramPool.Dispose();
 
       if (currentTask != null) await currentTask;

branches/PushGP/HeuristicLab.PushGP/HeuristicLab.Problems.ProgramSynthesis/Push/Interpreter/PushInterpreterPool.cs

@@ -1 +1 @@
 namespace HeuristicLab.Problems.ProgramSynthesis.Push.Interpreter {
   using System;
-
-  using HeuristicLab.Problems.ProgramSynthesis.Push.Data.Pool;
   using HeuristicLab.Core;
   using HeuristicLab.Problems.ProgramSynthesis.Push.Configuration;
+  using HeuristicLab.Problems.ProgramSynthesis.Push.Data.Pool;
+  using HeuristicLab.Problems.ProgramSynthesis.Push.Expressions;
   using HeuristicLab.Random;
 
   public class PushInterpreterPool {
     private readonly ObjectPool<PooledPushInterpreter> pool;
+    private ManagedPoolProvider<PushProgram> pushProgramPoolProvider;
 
     public PushInterpreterPool(PushConfiguration config = null)
-      : this(Environment.ProcessorCount * 2, config) {
+      : this(Environment.ProcessorCount * 2, 1024, null, config) {
     }
 
-    public PushInterpreterPool(int size, PushConfiguration config = null) {
-      this.PushGpConfiguration = config ?? new PushConfiguration();
+    public PushInterpreterPool(int size, int pushProgramPoolPartitionSize, int? maxPartitionCount = null, PushConfiguration config = null) {
+      PushGpConfiguration = config ?? new PushConfiguration();
 
-      this.pool = new ObjectPool<PooledPushInterpreter>(() => new PooledPushInterpreter(this, this.PushGpConfiguration), size);
+      pushProgramPoolProvider = new ManagedPoolProvider<PushProgram>(pushProgramPoolPartitionSize, maxPartitionCount);
+      pushProgramPoolProvider.InitDummyPartition(() => new PushProgram());
+
+      pool = new ObjectPool<PooledPushInterpreter>(() => new PooledPushInterpreter(this, PushGpConfiguration, pushProgramPoolProvider), size);
     }