async Task Worker(string imagePath, SemaphoreSlim semaphore)
{
    while (true)
    {
        var sw = Stopwatch.StartNew();
        var stream = new FileStream(imagePath, FileMode.Open);
        await CompressSkiaSharp(stream, semaphore);
        sw.Stop();
        Console.WriteLine($"Elapsed: {sw.ElapsedMilliseconds}ms");
    }

}

async Task Main()
{
    var semaphore = new SemaphoreSlim(50);
    var tasks = new List<Task>();
    var imagePath =
        @"/Users/eli/RiderProjects/ImageSharpProfilingFr/ImageSharpProfilingFr/qa3w10439tyq47tt0w144te9fi247hiyfer56poy7r3ae134h19EwpQs625GEhO38AGUyrU54yEwfG5w6hE34OE5Q9DOQ0hO1EhD.jpg";
    
    for (var i = 0; i < 50; i++)
    {
        tasks.Add(Worker(imagePath, semaphore));
    }
    
    await Task.WhenAll(tasks);
}

Main().Wait();

async Task Worker(string imagePath, SemaphoreSlim semaphore)
{
    while (true)
    {
        var sw = Stopwatch.StartNew();
        var stream = new FileStream(imagePath, FileMode.Open);
        await CompressSkiaSharp(stream, semaphore);
        sw.Stop();
        Console.WriteLine($"Elapsed: {sw.ElapsedMilliseconds}ms");
    }

}

async Task Main()
{
    var semaphore = new SemaphoreSlim(50);
    var tasks = new List<Task>();
    var imagePath =
        @"/Users/eli/RiderProjects/ImageSharpProfilingFr/ImageSharpProfilingFr/qa3w10439tyq47tt0w144te9fi247hiyfer56poy7r3ae134h19EwpQs625GEhO38AGUyrU54yEwfG5w6hE34OE5Q9DOQ0hO1EhD.jpg";
    
    for (var i = 0; i < 50; i++)
    {
        tasks.Add(Worker(imagePath, semaphore));
    }
    
    await Task.WhenAll(tasks);
}

Main().Wait();

async Task<Stream> CompressSkiaSharp(Stream imageStream, SemaphoreSlim semaphore, int maxWidth = 1000, int maxHeight = 1000)
{
    try
    {
        await semaphore.WaitAsync();
        imageStream.Position = 0;

        var outputStream = new MemoryStream();
        
        // Load the image data
        using var original = SKBitmap.Decode(imageStream);
        if (original == null) throw new InvalidOperationException("Failed to load image");
        
        var currentWidth = original.Width;
        var currentHeight = original.Height;

        // Calculate new dimensions while maintaining aspect ratio
        var newMaxWidth = Math.Min(currentWidth, maxWidth);
        var newMaxHeight = Math.Min(currentHeight, maxHeight);
        
        var ratioX = (double)newMaxWidth / currentWidth;
        var ratioY = (double)newMaxHeight / currentHeight;
        var ratio = Math.Min(ratioX, ratioY);
        
        var newWidth = (int)(currentWidth * ratio);
        var newHeight = (int)(currentHeight * ratio);

        // Create resized bitmap
        using var resized = original.Resize(new SKImageInfo(newWidth, newHeight), new SKSamplingOptions());
        if (resized == null) throw new InvalidOperationException("Failed to resize image");
        
        // Convert bitmap to image for encoding
        using var image = SKImage.FromBitmap(resized);
        
        // Encode as WebP
        using var data = image.Encode(SKEncodedImageFormat.Webp, 100);
        
        // Write to output stream
        data.SaveTo(outputStream);
        outputStream.Position = 0;

        return outputStream;
    }
    finally
    {
        semaphore.Release();
    }
}

async Task<Stream> CompressSkiaSharp(Stream imageStream, SemaphoreSlim semaphore, int maxWidth = 1000, int maxHeight = 1000)
{
    try
    {
        await semaphore.WaitAsync();
        imageStream.Position = 0;

        var outputStream = new MemoryStream();
        
        // Load the image data
        using var original = SKBitmap.Decode(imageStream);
        if (original == null) throw new InvalidOperationException("Failed to load image");
        
        var currentWidth = original.Width;
        var currentHeight = original.Height;

        // Calculate new dimensions while maintaining aspect ratio
        var newMaxWidth = Math.Min(currentWidth, maxWidth);
        var newMaxHeight = Math.Min(currentHeight, maxHeight);
        
        var ratioX = (double)newMaxWidth / currentWidth;
        var ratioY = (double)newMaxHeight / currentHeight;
        var ratio = Math.Min(ratioX, ratioY);
        
        var newWidth = (int)(currentWidth * ratio);
        var newHeight = (int)(currentHeight * ratio);

        // Create resized bitmap
        using var resized = original.Resize(new SKImageInfo(newWidth, newHeight), new SKSamplingOptions());
        if (resized == null) throw new InvalidOperationException("Failed to resize image");
        
        // Convert bitmap to image for encoding
        using var image = SKImage.FromBitmap(resized);
        
        // Encode as WebP
        using var data = image.Encode(SKEncodedImageFormat.Webp, 100);
        
        // Write to output stream
        data.SaveTo(outputStream);
        outputStream.Position = 0;

        return outputStream;
    }
    finally
    {
        semaphore.Release();
    }
}

async Task<Stream> CompressImageSharp(Stream imageStream, SemaphoreSlim semaphore, int maxWidth=1000, int maxHeight=1000)
{
    try
    {
        await semaphore.WaitAsync();
        imageStream.Position = 0; // Reset the stream position in case the stream has already been ready before.

        var outputStream = new MemoryStream();
        using var image = await Image.LoadAsync(imageStream);

        var currentWidth = image.Width;
        var currentHeight = image.Height;

        var newMaxWidth = Math.Min(currentWidth, maxWidth);
        var newMaxHeight = Math.Min(currentHeight, maxHeight);

        var resizeOptions = new ResizeOptions
        {
            Size = new Size(newMaxWidth, newMaxHeight),
        };

        image.Mutate(x => x.Resize(resizeOptions));

        var encoder = new WebpEncoder
        {
            Quality = 100,
            FileFormat = WebpFileFormatType.Lossy
        };

        await image.SaveAsync(outputStream, encoder);

        outputStream.Position = 0;

        return outputStream;
    }
    finally
    {
        semaphore.Release();
    }
}

async Task<Stream> CompressImageSharp(Stream imageStream, SemaphoreSlim semaphore, int maxWidth=1000, int maxHeight=1000)
{
    try
    {
        await semaphore.WaitAsync();
        imageStream.Position = 0; // Reset the stream position in case the stream has already been ready before.

        var outputStream = new MemoryStream();
        using var image = await Image.LoadAsync(imageStream);

        var currentWidth = image.Width;
        var currentHeight = image.Height;

        var newMaxWidth = Math.Min(currentWidth, maxWidth);
        var newMaxHeight = Math.Min(currentHeight, maxHeight);

        var resizeOptions = new ResizeOptions
        {
            Size = new Size(newMaxWidth, newMaxHeight),
        };

        image.Mutate(x => x.Resize(resizeOptions));

        var encoder = new WebpEncoder
        {
            Quality = 100,
            FileFormat = WebpFileFormatType.Lossy
        };

        await image.SaveAsync(outputStream, encoder);

        outputStream.Position = 0;

        return outputStream;
    }
    finally
    {
        semaphore.Release();
    }
}