Program.cs

// ***************************************************************************************
// MIT LICENCE
// The maintenance and evolution is maintained by the RingBufferPlus project under MIT license
// ***************************************************************************************

using System.Diagnostics;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using RingBufferPlus;

namespace RingBufferPlusBasicSample
{
    public class Program
    {
        private static IHost? HostApp = null;
        public static async Task Main(string[] args)
        {

            Console.WriteLine("Example of RingBufferPlus - Basic usage with fixed capacity and HeartBeat(10 sec.)");
            Console.WriteLine("==================================================================================");
            Console.WriteLine("");

            HostApp = CreateHostBuilder(args).Build();

            //token to gracefull shutdown
            var tokenapplifetime = HostApp.Services.GetService<IHostApplicationLifetime>()!.ApplicationStopping;

            Random rnd = new();

            var rb = await RingBuffer<int>.New("MyBuffer")
                .Capacity(3)
                .Logger(HostApp.Services.GetService<ILogger<Program>>())
                .Factory((_) => { return Task.FromResult(rnd.Next(1, 10)); })
                .HeartBeat(MyHeartBeat)
                .BuildWarmupAsync(tokenapplifetime);

            Console.WriteLine($"Ring Buffer name({rb.Name}) created.");
            Console.WriteLine($"Ring Buffer Current capacity is : {rb.CurrentCapacity}");
            Console.WriteLine($"Ring Buffer name({rb.Name}) IsInitCapacity = {rb.IsInitCapacity}.");
            Console.WriteLine($"Ring Buffer name({rb.Name}) IsMaxCapacity = {rb.IsMaxCapacity}.");
            Console.WriteLine($"Ring Buffer name({rb.Name}) IsMinCapacity = {rb.IsMinCapacity}.");

            Console.WriteLine("Press anykey to start 2 Acquire buffer");
            Console.ReadKey();
            using (var buffer1 = await rb.AcquireAsync(tokenapplifetime))
            {
#pragma warning disable IDE0063 // Use simple 'using' statement
                using (var buffer2 = await rb.AcquireAsync(tokenapplifetime))
                {
                    Console.WriteLine($"Buffer is ok({buffer1.Successful}:{buffer1.ElapsedTime}) value: {buffer1.Current}");
                    Console.WriteLine($"Buffer is ok({buffer2.Successful}:{buffer2.ElapsedTime}) value: {buffer2.Current}");
                }
#pragma warning restore IDE0063 // Use simple 'using' statement
            }

            Console.WriteLine("Press anykey to Acquire buffer and invalidate item buffer");
            Console.ReadKey();
            using (var buffer3 = await rb.AcquireAsync(tokenapplifetime))
            {
                Console.WriteLine($"Buffer is ok({buffer3.Successful}:{buffer3.ElapsedTime}) value: {buffer3.Current}");
                buffer3.Invalidate();
            }

            Console.WriteLine($"Dispose Ring Buffer...");
            rb.Dispose();
            var sw = Stopwatch.StartNew();
            while (sw.ElapsedMilliseconds < 5000)
            {
                Thread.Sleep(1000);
                Console.WriteLine($"Ring Buffer Current is {rb.CurrentCapacity}");
            }
            sw.Reset();
        }

        private static void MyHeartBeat(RingBufferValue<int> value)
        {
            //do anything with value ex: health check
        }

        private static IHostBuilder CreateHostBuilder(string[] args) =>
            Host.CreateDefaultBuilder(args)
                .ConfigureLogging((hostContext, logbuilder) =>
                {
                    logbuilder
                        .SetMinimumLevel(LogLevel.Debug)
                        .AddFilter("Microsoft", LogLevel.Warning)
                        .AddFilter("System", LogLevel.Warning)
                        .AddConsole();
                });
    }
}