BlockingObjectPool

BlockingObjectPool.fs

type BlockingObjectPool<'T when 'T : (new : unit -> 'T)>(maxCount : int) =
    let pool = Stack<'T>(maxCount)
    let semaphoreSlim = new SemaphoreSlim(maxCount, maxCount)
    do for i=0 to maxCount do
        let foo = new 'T()
        pool.Push(foo)

    member _.Get() =
        printf $"Getting from pool : {semaphoreSlim.CurrentCount}"
        semaphoreSlim.Wait()
        pool.Pop()

    member _.GetAsync() = task {
        printf $"Getting from pool : {semaphoreSlim.CurrentCount}"
        do! semaphoreSlim.WaitAsync()
        return pool.Pop()
    }

    member _.Return(item : 'T) =
        printf "Returning to pool"
        pool.Push(item)
        semaphoreSlim.Release() |> ignore

    interface IDisposable with
        member this.Dispose(): unit =
            pool.Clear()
            semaphoreSlim.Dispose()