Ожидает ActionBlock <T> - TPL DataFlow

Question

Я использую TPL DataFlow и ActionBlock для создания параллелизма. Причина использования TPL DataFlow заключается в том, что он поддерживает асинхронность, за исключением того, что я не могу заставить его работать.

var ab = new ActionBlock<Group>(async group => 
{ 
    try { 
     labelStatus.Text = "Getting admins from " + group.Gid; 
     await GetAdminsFromGroup(group.Gid); 
    }catch (ArgumentOutOfRangeException ex) { 
     // Log exception 
    } 

}, new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 10 }); 

db.Groups.ToList().ForEach(i => ab.Post(i)); 

ab.Complete(); 

MessageBox.Show("Complete"); 

Поле сообщения отображается почти мгновенно, хотя ActionBlocks все еще работают. Как я могу await до завершения ActionBlock?

Answer 1

ActionBlock<T> предоставляет объект Completion. Это Task, который завершается, когда блок завершил обработку всего. Таким образом, вы можете ждать, что:

ab.Complete(); 
await ab.Completion; 
MessageBox.Show("Complete"); 

Я должен признать, что я не использовал TPL Dataflow себя, но примеры показывают, что должно быть в порядке.