ExamplesLocksPoolAsync.cs

using System;
using System.Diagnostics.CodeAnalysis;
using System.Threading;
using System.Threading.Tasks;
using NUnit.Framework;
using Acme.Wattle.DomainObjects;
using Acme.Wattle.DomainObjects.Common;
using Acme.Wattle.DomainObjects.Interfaces;

namespace Acme.Wattle.Examples.Locks;

/// <summary>
/// Примеры асинхронного пула лок-объектов ассоциированных с идентификаторами.
/// </summary>
[TestFixture]
[SuppressMessage("ReSharper", "AccessToDisposedClosure")]
[SuppressMessage("ReSharper", "RedundantArgumentDefaultValue")]
public class ExamplesLocksPoolAsync
{
    /// <summary>
    /// Основные функции.
    /// </summary>
    [Test]
    public async Task Example_Async()
    {
        using var locks = 
            new LocksPoolAsync<int>(
                Guid.NewGuid(), 
                "Тест", 
                "Тест", 
                new TimeService(), 
                TimeSpan.FromSeconds(2));  // Ожидание монопольной блокировки 2 секунды.

        // Монитор инфраструктуры лок-объектов.
        var infrastructureMonitor = ((ILocksPoolAsync<int>)locks).InfrastructureMonitor;

        // Получаем монопольную блокировку
        using (var lockObject = locks.GetLock(123))
        {
            if (await lockObject.TryEnterAsync(CancellationToken.None))
            {
                Console.WriteLine("Enter");
            }
            else
            {
                Assert.Fail();
            }
        }

        // Проверяем число успешных блокировок.
        var snapShot = infrastructureMonitor.GetSnapShot();
        Assert.AreEqual(1, snapShot.CountEnter);
        Assert.AreEqual(0, snapShot.CountNotEnter);

        // Получаем монопольную блокировку на длительное время
        var task = Task.Factory.StartNew(
            () =>
            {
                Console.WriteLine("Task - Start");

                using (var lockObject = locks.GetLock(123))
                {
                    if (lockObject.TryEnter())
                    {
                        Console.WriteLine("Task Enter");

                        Thread.Sleep(TimeSpan.FromSeconds(10));
                    }
                    else
                    {
                        Assert.Fail();
                    }
                }

                Console.WriteLine("Task - End");
            });

        Thread.Sleep(TimeSpan.FromSeconds(5));

        // Попытка получения монопольной блокировки с ожиданием 2-х секунд
        using (var lockObject = locks.GetLock(123))
        {
            if (false == await lockObject.TryEnterAsync(CancellationToken.None))
            {
                Console.WriteLine("Not Enter");
            }
            else
            {
                Assert.Fail();
            }
        }

        task.Wait();

        // Проверяем число успешных блокировок.
        snapShot = infrastructureMonitor.GetSnapShot();
        Assert.AreEqual(2, snapShot.CountEnter);
        Assert.AreEqual(1, snapShot.CountNotEnter);
    }

    /// <summary>
    /// Основные функции.
    /// Ожидание монопольной блокировки бесконечно.
    /// </summary>
    [Test]
    public async Task Example_WaitInitity_Async()
    {
        using var locks =
            new LocksPoolAsync<int>(
                Guid.NewGuid(),
                "Тест",
                "Тест",
                new TimeService(),
                null /* Ожидание монопольной блокировки бесконечно. */); 

        // Монитор инфраструктуры лок-объектов.
        var infrastructureMonitor = ((ILocksPoolAsync<int>)locks).InfrastructureMonitor;

        // Получаем монопольную блокировку
        using (var lockObject = locks.GetLock(123))
        {
            if (await lockObject.TryEnterAsync(CancellationToken.None))
            {
                Console.WriteLine("Enter");
            }
            else
            {
                Assert.Fail();
            }
        }

        // Проверяем число успешных блокировок.
        var snapShot = infrastructureMonitor.GetSnapShot();
        Assert.AreEqual(1, snapShot.CountEnter);
        Assert.AreEqual(0, snapShot.CountNotEnter);

        // Получаем монопольную блокировку на длительное время
        var task = Task.Factory.StartNew(
            () =>
            {
                Console.WriteLine("Task - Start");

                using (var lockObject = locks.GetLock(123))
                {
                    if (lockObject.TryEnter())
                    {
                        Console.WriteLine("Task Enter");

                        Thread.Sleep(TimeSpan.FromSeconds(10));
                    }
                    else
                    {
                        Assert.Fail();
                    }
                }

                Console.WriteLine("Task - End");
            });

        Thread.Sleep(TimeSpan.FromSeconds(5));

        // Попытка получения монопольной блокировки с ожиданием 2-х секунд
        using (var lockObject = locks.GetLock(123))
        {
            if (await lockObject.TryEnterAsync(CancellationToken.None))
            {
                Console.WriteLine("Enter");
            }
            else
            {
                Assert.Fail();
            }
        }

        task.Wait();

        // Проверяем число успешных блокировок.
        snapShot = infrastructureMonitor.GetSnapShot();
        Assert.AreEqual(3, snapShot.CountEnter);
        Assert.AreEqual(0, snapShot.CountNotEnter);
    }
}