Changeset 14746 for branches/PushGP/HeuristicLab.PushGP/TestPooling/Pool

Timestamp:

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

Author:

pkimmesw

Message:

#2665 PooledPushProgram reduces memory usage and increases performance

Location:

branches/PushGP/HeuristicLab.PushGP/TestPooling/Pool

Files:

• IManagedPool.cs (deleted)
• ManagedPool2.cs (deleted)
• ManagedPoolProvider.cs (modified) (2 diffs)

branches/PushGP/HeuristicLab.PushGP/TestPooling/Pool/ManagedPoolProvider.cs

@@ -8 +8 @@
   using System.Runtime.Serialization.Formatters.Binary;
 
+  public interface IManagedPool<T> : IDisposable where T : class {
+    T Get();
+  }
+
   public class ManagedPoolProvider<T> where T : class {
     private readonly ConcurrentStack<T[]> partitions = new ConcurrentStack<T[]>();
     private readonly ObjectPool<IManagedPool<T>> managedPools;
     private T[] DummyPartition;
+
     public readonly int PartitionSize;
+    public readonly int MaxParitionCount;
+    public const int DefaultMaxInstanceCount = 16384;
 
-    public int InstanceCount { get { return partitions.Count * PartitionSize; } }
+    public ManagedPoolProvider(int partitionSize, int maxPartitionCount = -1) {
+      PartitionSize = partitionSize;
 
-    public ManagedPoolProvider(int partitionSize) {
-      PartitionSize = partitionSize;
+      if (maxPartitionCount <= 0) {
+        MaxParitionCount = DefaultMaxInstanceCount / PartitionSize;
+      }
+
       managedPools = new ObjectPool<IManagedPool<T>>(() => new ManagedPool2<T>(this));
     }
@@ -27 +37 @@
       }
     }
+
+    public int InstanceCount { get { return partitions.Count * PartitionSize; } }
 
     public void ReleasePartitions(params T[][] partition) {