Асинхронно ждать появления n вещей

Question

Я ищу что-то вроде Semaphore, но это разрешает после того, как все слоты выпущены.

Что-то вроде этого:

use semaphore = new SemaphoreSlim(0,100) 

anEvent.add(fun _ -> semaphore.Release(1) |> ignore); 

async { 
    do! thingThatCausesAnEventToFire100Times() 
    //where 100 is the available slots instead of the timeout. 
    let! thingsHappened = semaphore.WaitAsync(100) |> Async.AwaitTask 
    thingsHappened |> should be True 
} 

Answer 1

Похоже, работа для MailboxProcessor. Как об этом:

type SemaphoreCommand = 
    |Release 
    |Wait of AsyncReplyChannel<unit> 

let semaphore slots = 
    Agent.Start 
    <| fun inbox -> 
     let rec loop c (w:AsyncReplyChannel<unit> list) = 
      async { 
      let! command = inbox.Receive() 
      match command with 
      |Release -> if (c + 1) = slots then w |> List.iter(fun t -> t.Reply()) 
         else return! loop (c + 1) w 
      |Wait a -> return! loop c (a::w) 
     } 
     loop 0 [] 

let slotWaiter = semaphore 100 

//Events will fill up slots 
Release |> slotWaiter.Post 
Release |> slotWaiter.Post 

async{ 
    //Wait for all slots to be filled 
    do! slotWaiter.PostAndAsyncReply(fun t -> Wait t) 
    //All slots filled - continue 
} 

Я не обрабатывает случай, когда вы можете не зарегистрировал AsyncReplyChannel к тому времени заполнены все слоты или сброса, когда все слоты заполнены, но это довольно тривиально, и я оставьте это как упражнение для читателя :)