class Program
{
	static async Task Main(string[] args)
	{
		System.Console.WriteLine("TicksPerSecond: " + TimeSpan.TicksPerSecond);
		System.Console.WriteLine("Frequency: " + Stopwatch.Frequency);

		var a1 = Stopwatch.GetTimestamp();
		await Task.Delay(100);
		var b1 = Stopwatch.GetTimestamp();
		Console.WriteLine($"{a1} - {b1} = {b1 - a1}");
		Console.WriteLine(TimeSpan.FromTicks(b1 - a1).TotalMilliseconds);

		ThreadPool.SetMinThreads(128, 128);

		ConnectionMultiplexer.SetFeatureFlag("preventthreadtheft", true);
		var a = await ConnectionMultiplexer.ConnectAsync("127.0.0.1");
		var db = a.GetDatabase(0);
		db.KeyTimeToLive("abc");
		await db.KeyTimeToLiveAsync("abc");

		var sesstion = new ServiceProfiler().GetSession();
		a.RegisterProfiler(() => sesstion);

		var sw = Stopwatch.StartNew();

		await Task.WhenAll(Enumerable.Range(0, 100)
			.Select(_ => Task.Run(async () =>
			{
				for (var index = 0; index < 100; index++)
				{
					//db.KeyTimeToLive("abc");
					await db.KeyTimeToLiveAsync("abc");
				}
			})));

		Console.WriteLine(sw.ElapsedMilliseconds);

		Console.WriteLine(JsonSerializer.Serialize(sesstion.FinishProfiling()
			.GroupBy(cmd => cmd.Command)
			.ToDictionary(group => group.Key,
				group => (object)new
				{
					Count = group.Count(),
					CreationToEnqueued = group.Average(cmd => cmd.CreationToEnqueued.TotalMilliseconds),
					EnqueuedToSending = group.Average(cmd => cmd.EnqueuedToSending.TotalMilliseconds),
					SentToResponse = group.Average(cmd => cmd.SentToResponse.TotalMilliseconds),
					ResponseToCompletion = group.Average(cmd => cmd.ResponseToCompletion.TotalMilliseconds),
					ElapsedTime = group.Average(cmd => cmd.ElapsedTime.TotalMilliseconds),
				}), new JsonSerializerOptions { WriteIndented = true }));
	}
}

public class ServiceProfiler
{
	private readonly AsyncLocal<ProfilingSession> _contextValue = new AsyncLocal<ProfilingSession>();

	public ProfilingSession GetSession() => _contextValue.Value ?? (_contextValue.Value = new ProfilingSession());
}