Changeset 14745 for branches/PushGP/HeuristicLab.PushGP/TestPooling/Pool/ManagedPool2.cs

Timestamp:

03/11/17 12:42:31 (7 years ago)

Author:

pkimmesw

Message:

#2665 Merged ExecExpandExpression and PushProgram due to performance reasons, Tested managed object pooling

File:

• branches/PushGP/HeuristicLab.PushGP/TestPooling/Pool/ManagedPool2.cs (modified) (1 diff)

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

@@ -1 @@
-using System.Collections.Generic;
+//using System.Collections.Generic;
 
-namespace TestPooling.Pool {
-  using System;
-  using System.Collections.Concurrent;
-  using System.IO;
-  using System.Linq;
-  using System.Runtime.Serialization.Formatters.Binary;
+//namespace TestPooling.Pool {
+//  using System;
+//  using System.Collections.Concurrent;
+//  using System.IO;
+//  using System.Linq;
+//  using System.Runtime.Serialization.Formatters.Binary;
 
-  public class ManagedPool2<T> : IDisposable where T : class {
+//  public class ManagedPool2<T> : IDisposable where T : class {
 
-    private static readonly ConcurrentStack<T[]> Pool = new ConcurrentStack<T[]>();
+//    private static readonly ConcurrentStack<T[]> Pool = new ConcurrentStack<T[]>();
 
-    private readonly T[] DummyPartition;
-    private readonly Func<T> Factory;
-    public readonly int PartitionSize;
+//    private readonly T[] DummyPartition;
+//    public readonly int PartitionSize;
 
-    private readonly IList<T[]> partitions = new List<T[]>();
-    private T[] currentPartition;
-    private int entryIndex;
+//    private readonly IList<T[]> partitions = new List<T[]>();
+//    private T[] currentPartition;
+//    private int entryIndex;
 
-    public ManagedPool2(int partitionSize, T[] dummyPartition, Func<T> factory) {
-      PartitionSize = partitionSize;
-      Factory = factory;
-      entryIndex = partitionSize;
+//    public ManagedPool2(int partitionSize, T[] dummyPartition) {
+//      PartitionSize = partitionSize;
+//      entryIndex = partitionSize;
 
-      DummyPartition = dummyPartition;
-    }
+//      DummyPartition = dummyPartition;
+//    }
 
-    public T Get() {
-      if (entryIndex == PartitionSize) {
-        currentPartition = GetPartition();
-        partitions.Add(currentPartition);
-        entryIndex = 0;
-      }
+//    public T Get() {
+//      if (entryIndex == PartitionSize) {
+//        currentPartition = GetPartition();
+//        partitions.Add(currentPartition);
+//        entryIndex = 0;
+//      }
 
-      return currentPartition[entryIndex++];
-    }
+//      return currentPartition[entryIndex++];
+//    }
 
-    private T[] GetPartition() {
-      //T[] partition;
+//    private T[] GetPartition() {
+//      T[] partition;
+//      return (Pool.TryPop(out partition)) ? partition : DeepArrayCopy(DummyPartition);
+//    }
 
-      //partition = Pool.TryPop(out partition) ? partition : new T[PartitionSize];
+//    private static T[] DeepArrayCopy(object objectToCopy) {
+//      using (var memoryStream = new MemoryStream()) {
+//        var binaryFormatter = new BinaryFormatter();
 
-      //for (var i = 0; i < PartitionSize; i++) {
-      //  partition[i] = Factory();
-      //}
+//        binaryFormatter.Serialize(memoryStream, objectToCopy);
+//        memoryStream.Seek(0, SeekOrigin.Begin);
 
-      //return partition;
+//        return (T[])binaryFormatter.Deserialize(memoryStream);
+//      }
+//    }
 
-      T[] partition;
-      if (Pool.TryPop(out partition)) return partition;
-
-      //partition = new T[PartitionSize];
-      //DummyPartition.CopyTo(partition, 0);
-
-      return DeepArrayCopy(DummyPartition);
-    }
-
-    private static T[] DeepArrayCopy(object objectToCopy) {
-      using (var memoryStream = new MemoryStream()) {
-        var binaryFormatter = new BinaryFormatter();
-
-        binaryFormatter.Serialize(memoryStream, objectToCopy);
-        memoryStream.Seek(0, SeekOrigin.Begin);
-
-        return (T[])binaryFormatter.Deserialize(memoryStream);
-      }
-    }
-
-    public void Dispose() {
-      Pool.PushRange(partitions.ToArray());
-    }
-  }
-}
+//    public void Dispose() {
+//      Pool.PushRange(partitions.ToArray());
+//      partitions.Clear();
+//    }
+//  }
+//}