attendere async lambda in ActionBlock

Question

Ho un ricevitore classe con un'ActionBlock:

public class Receiver<T> : IReceiver<T> 
{ 

    private ActionBlock<T> _receiver; 

    public Task<bool> Send(T item) 
    { 
    if(_receiver!=null) 
     return _receiver.SendAsync(item); 

    //Do some other stuff her 
    } 

    public void Register (Func<T, Task> receiver) 
    { 
    _receiver = new ActionBlock<T> (receiver); 
    } 

    //... 
} 

Il registro-azione per l'ActionBlock è un async-metodo con un await-Statement:

private static async Task Writer(int num) 
{ 
    Console.WriteLine("start " + num); 
    await Task.Delay(500); 
    Console.WriteLine("end " + num); 
} 

Ora quello che voglio fare è attendere sincrono (se una condizione è impostata) fino a quando il metodo azione è finito per ottenere un comportamento esclusivo:

var receiver = new Receiver<int>(); 
receiver.Register((Func<int, Task) Writer); 
receiver.Send(5).Wait(); //does not wait the action-await here! 

Il problema è quando "attendi Task.Delay (500);" l'istruzione è eseguita, il "receiver.Post (5) .Wait();" non aspetta più

Ho provato diverse varianti (TaskCompletionSource, ContinueWith, ...) ma non funziona.

Qualcuno ha un'idea di come risolvere il problema?

Answer 1

ActionBlock per impostazione predefinita applica il comportamento esclusivo (viene elaborato un solo elemento alla volta). Se si intende qualcos'altro da un "comportamento esclusivo", è possibile utilizzare TaskCompletionSource per informare il mittente quando l'azione è completa:

... use ActionBlock<Tuple<int, TaskCompletionSource<object>>> and Receiver<Tuple<int, TaskCompletionSource<object>>> 
var receiver = new Receiver<Tuple<int, TaskCompletionSource<object>>>(); 
receiver.Register((Func<Tuple<int, TaskCompletionSource<object>>, Task) Writer); 
var tcs = new TaskCompletionSource<object>(); 
receiver.Send(Tuple.Create(5, tcs)); 
tcs.Task.Wait(); // if you must 

private static async Task Writer(int num, TaskCompletionSource<object> tcs) 
{ 
    Console.WriteLine("start " + num); 
    await Task.Delay(500); 
    Console.WriteLine("end " + num); 
    tcs.SetResult(null); 
} 

In alternativa, è possibile utilizzare AsyncLock (included in my AsyncEx library):

private static AsyncLock mutex = new AsyncLock(); 

private static async Task Writer(int num) 
{ 
    using (await mutex.LockAsync()) 
    { 
    Console.WriteLine("start " + num); 
    await Task.Delay(500); 
    Console.WriteLine("end " + num); 
    } 
}