using System;

using System.Threading;

using System.Threading.Tasks;

​

public interface IInputRequest { }

​

public class InputRequest : IInputRequest { }

​

public delegate void PackInputRequestedEventHandler(IStorageSystem sender, IInputRequest request);

​

public interface IStorageSystem

{

    int SubscriberId { get; }

    event PackInputRequestedEventHandler PackInputRequested;

    void Connect(string host, ushort port);

    void Subscribe();

    void RequestPackInput();

}

​

public class RowaStorageSystem : IStorageSystem

{

    public int SubscriberId { get; private set; }

    private static RowaStorageSystem latestSubscriber;

    public event PackInputRequestedEventHandler PackInputRequested;

​

    public RowaStorageSystem(int subscriberId)

    {

        SubscriberId = subscriberId;

    }

​

    public void Connect(string host, ushort port)

    {

        // Simulate connection logic

        Console.WriteLine($"Connected to {host}:{port} with SubscriberId {SubscriberId}");

    }

​

    public void Subscribe()

    {

        latestSubscriber = this;

    }

​

    public void RequestPackInput()

    {

        // Ensure only the latest subscriber handles the event

        if (latestSubscriber == this)

        {

            PackInputRequested?.Invoke(this, new InputRequest());

        }

    }

}

​

public class Program

{

    private static Random random = new Random();

​

    public static void Main()

    {

        var storageSystem1 = new RowaStorageSystem(1);

        var storageSystem2 = new RowaStorageSystem(2);

​

        storageSystem1.PackInputRequested += StorageSystem_PackInputRequested;

        storageSystem2.PackInputRequested += StorageSystem_PackInputRequested;

​

        // Simulate connection and subscription at random intervals

        Task.Run(() => ConnectAndSubscribeWithDelay(storageSystem1, "localhost", 12345));

        Task.Run(() => ConnectAndSubscribeWithDelay(storageSystem2, "localhost", 12345));

​

        // Simulate event triggering at random intervals

        Task.Run(() => TriggerEventWithDelay(storageSystem1));

        Task.Run(() => TriggerEventWithDelay(storageSystem2));

​

        // Prevent the main thread from exiting immediately

        Thread.Sleep(10000);

    }

​

    private static void ConnectAndSubscribeWithDelay(RowStorageSystem storageSystem, string host, ushort port)

    {

        // Random delay between 1 and 5 seconds

        int delay = random.Next(1000, 5000);

        Thread.Sleep(delay);

​

        storageSystem.Connect(host, port);

        storageSystem.Subscribe();

    }

​

    private static void TriggerEventWithDelay(RowStorageSystem storageSystem)

    {

        // Random delay between 1 and 5 seconds

        int delay = random.Next(1000, 5000);

        Thread.Sleep(delay);

​

        storageSystem.RequestPackInput();

    }

​

    private static void StorageSystem_PackInputRequested(IStorageSystem sender, IInputRequest request)

    {

        Console.WriteLine($"Event received from StorageSystem {sender.SubscriberId} on thread {Thread.CurrentThread.ManagedThreadId}");

    }

}

​