erwarten async Lambda in ActionBlock

Question

ich ein Klasse-Receiver mit einem ActionBlock habe:

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); 
    } 

    //... 
} 

Die Register-Aktion für den ActionBlock ist eine Asynchron-Methode mit einem await-Statement:

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

Jetzt was ich tun möchte, ist, synchron zu warten (wenn eine Bedingung eingestellt ist), bis die Aktionsmethode beendet ist, um ein exklusives Verhalten zu erhalten:

Das Problem ist, wenn die "warten auf Task.Delay (500);" Anweisung ausgeführt wird, die "receiver.Post (5) .Wait();" wartet nicht mehr.

Ich habe mehrere Varianten (TaskCompletionSource, ContinueWith, ...) versucht, aber es funktioniert nicht.

Hat jemand eine Idee, wie man das Problem löst?

Answer 1

ActionBlock wird standardmäßig exklusives Verhalten erzwingen (es wird jeweils nur ein Element verarbeitet). Wenn Sie etwas anderes von „exklusiven Verhalten“ bedeuten, können Sie TaskCompletionSource verwenden Ihren Absender zu benachrichtigen, wenn die Aktion abgeschlossen ist:

... 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); 
} 

Alternativ können Sie verwenden 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); 
    } 
}