Remove SkipLast method (now in .net core), and add instance based BucketTimer

Author: Eric White

OpenXmlPowerTools/PtUtil.cs

@@ -797,23 +797,23 @@ public static IEnumerable<TSource> SequenceAt<TSource>(this TSource[] source, in
  yield return source[i++];
  }
 
- public static IEnumerable<T> SkipLast<T>(this IEnumerable<T> source, int count)
- {
- var saveList = new Queue<T>();
- var saved = 0;
- foreach (T item in source)
- {
- if (saved < count)
- {
- saveList.Enqueue(item);
- ++saved;
- continue;
- }
-
- saveList.Enqueue(item);
- yield return saveList.Dequeue();
- }
- }
+ //public static IEnumerable<T> SkipLast<T>(this IEnumerable<T> source, int count)
+ //{
+ // var saveList = new Queue<T>();
+ // var saved = 0;
+ // foreach (T item in source)
+ // {
+ // if (saved < count)
+ // {
+ // saveList.Enqueue(item);
+ // ++saved;
+ // continue;
+ // }
+
+ // saveList.Enqueue(item);
+ // yield return saveList.Dequeue();
+ // }
+ //}
 
  public static bool? ToBoolean(this XAttribute a)
  {
@@ -1169,6 +1169,128 @@ IEnumerator<TSource> IEnumerable<TSource>.GetEnumerator()
  }
  }
 
+ // this is fundamentally the same as PtBucketTimer, except that it is instance based,
+ // not a static class.
+ public class BucketTimer
+ {
+ public BucketTimer()
+ {
+ Buckets = new Dictionary<string, BucketInfo>();
+ }
+
+ private class BucketInfo
+ {
+ public int Count;
+ public TimeSpan Time;
+ }
+
+ private string LastBucket = null;
+ private DateTime LastTime;
+ private Dictionary<string, BucketInfo> Buckets;
+
+ public void Bucket(string bucket)
+ {
+ DateTime now = DateTime.Now;
+ if (LastBucket != null)
+ AddToBuckets(now);
+ LastBucket = bucket;
+ LastTime = now;
+ }
+
+ public void End()
+ {
+ DateTime now = DateTime.Now;
+ if (LastBucket != null)
+ AddToBuckets(now);
+ LastBucket = null;
+ }
+
+ private void AddToBuckets(DateTime now)
+ {
+ TimeSpan d = now - LastTime;
+ var bucketParts = LastBucket.Split('/');
+ var bucketList = bucketParts.Select((t, i) => bucketParts
+ .Take(i + 1)
+ .Select(z => z + "/")
+ .StringConcatenate()
+ .Trim('/'))
+ .ToList();
+
+ foreach (var b in bucketList)
+ {
+ if (Buckets.ContainsKey(b))
+ {
+ Buckets[b].Count = Buckets[b].Count + 1;
+ Buckets[b].Time += d;
+ }
+ else
+ {
+ Buckets.Add(b, new BucketInfo()
+ {
+ Count = 1,
+ Time = d,
+ });
+ }
+ }
+ LastTime = now;
+ }
+
+ public string DumpBucketsByKey()
+ {
+ StringBuilder sb = new StringBuilder();
+ foreach (var bucket in Buckets.OrderBy(b => b.Key))
+ {
+ string ts = bucket.Value.Time.ToString();
+ if (ts.Contains('.'))
+ ts = ts.Substring(0, ts.Length - 5);
+ string s = bucket.Key.PadRight(60, '-') + " " + string.Format("{0:00000000}", bucket.Value.Count) + " " + ts;
+ sb.Append(s + Environment.NewLine);
+ }
+ TimeSpan total = Buckets
+ .Aggregate(TimeSpan.Zero, (t, b) => t + b.Value.Time);
+ var tz = total.ToString();
+ sb.Append(string.Format("Total: {0}", tz.Substring(0, tz.Length - 5)));
+ return sb.ToString();
+ }
+
+ public string DumpBucketsToCsvByKey()
+ {
+ StringBuilder sb = new StringBuilder();
+ foreach (var bucket in Buckets.OrderBy(b => b.Key))
+ {
+ string ts = bucket.Value.Time.ToString();
+ if (ts.Contains('.'))
+ ts = ts.Substring(0, ts.Length - 5);
+ string s = bucket.Key + "," + bucket.Value.Count.ToString() + "," + ts;
+ sb.Append(s + Environment.NewLine);
+ }
+ return sb.ToString();
+ }
+
+ public string DumpBucketsByTime()
+ {
+ StringBuilder sb = new StringBuilder();
+ foreach (var bucket in Buckets.OrderBy(b => b.Value.Time))
+ {
+ string ts = bucket.Value.Time.ToString();
+ if (ts.Contains('.'))
+ ts = ts.Substring(0, ts.Length - 5);
+ string s = bucket.Key.PadRight(60, '-') + " " + string.Format("{0:00000000}", bucket.Value.Count) + " " + ts;
+ sb.Append(s + Environment.NewLine);
+ }
+ TimeSpan total = Buckets
+ .Aggregate(TimeSpan.Zero, (t, b) => t + b.Value.Time);
+ var tz = total.ToString();
+ sb.Append(string.Format("Total: {0}", tz.Substring(0, tz.Length - 5)));
+ return sb.ToString();
+ }
+
+ public void Init()
+ {
+ Buckets = new Dictionary<string, BucketInfo>();
+ }
+ }
+
  public static class PtBucketTimer
  {
  private class BucketInfo