using System.Runtime.CompilerServices;
using System.Collections.Concurrent;
using System.Diagnostics;
using System.Threading.Tasks;
using System;
using System.Collections.Generic;
using System.Linq;

namespace Spw.Snowflake
{
    class Program
    {
        static void Main(string[] args)
        {
            var ids = new ConcurrentStack<long>();
            var sfc = new SnowFlakeCore(1605250175746, 1, 1);
            var sw = new Stopwatch();
            sw.Start();
            var pr = Parallel.For(0, 1000000, i =>
            {
                ids.Push(sfc.GenerateId());
            });

            while (!pr.IsCompleted) { }

            sw.Stop();
            Console.WriteLine($"spent {sw.ElapsedMilliseconds}, id count {ids.Count}");

            var repeatIds = ids.GroupBy(x => x).Where(s => s.Count() > 1);

            // foreach (var id in repeatIds)
            // {
            //     Console.WriteLine($"key -> {id.Key}, count -> {id.Count()}");
            // }

            Console.WriteLine($"repeat count {repeatIds.Count()}");

            // while (!ids.IsEmpty)
            // {
            //     ids.TryPop(out var id);
            //     Console.WriteLine(id);
            // }
        }
    }
}