eseguire un task gruppo asincrone quando un certo ordine di esecuzione deve essere preservato

Question

Sto cercando di asynchronize il mio codice originale

for(var item in items) 
{ 
    dbAccess.Save(item); 
} 

che funziona bene:

var tasks = new List<Task>(); 

    for(var item in items) 
    { 
     tasks.Add(dbAccess.SaveAsync(item)); 
    } 

    await Task.WhenAll(tasks); 

Tuttavia, ho bisogno di aggiungere un ulteriore clean-up call prima di salvare e oggetto ai miei DB:

var tasks = new List<Task>(); 

    for(var item in items) 
    { 
     tasks.Add(dbAccess.DeleteAsync(item.id)); 
     tasks.Add(dbAccess.SaveAsync(item)); 
    } 

    await Task.WhenAll(tasks); 

Questo codice di cui sopra non è corretto in quanto SaveAs ync non dovrebbe essere eseguito fino al completamento del DeleteAsync corrispondente. In altre parole, la cancellazione deve sempre andare prima del salvataggio per ogni articolo, ma l'ordine degli articoli non ha importanza.

Esiste un modo perfetto per farlo?

Answer 1

Creare un metodo async che esegue l'eliminazione, quindi il salvataggio, per un singolo elemento, e di eseguire tutte quelle operazioni composite su ogni elemento in parallelo:

var tasks = items.Select(async item => 
{ 
    await dbAccess.DeleteAsync(item.id); 
    await dbAccess.SaveAsync(item); 
}); 
await Task.WhenAll(tasks); 

Answer 2

È possibile utilizzare un Func<Task> per incapsulare le due chiamate asincrone in un unico Task come questo:

for(var item in items) 
{ 
    //We store the value of item in a local variable 
    //because it is not recommended to close over a loop variable 
    var my_item = item; 

    Func<Task> task_fact = async() => 
    { 
     await dbAccess.DeleteAsync(my_item.id); 
     await dbAccess.SaveAsync(my_item); 
    }; 

    tasks.Add(task_fact()); 
} 

Questo creerà un compito che chiama il metodo di eliminazione, in modo asincrono aspettare che si, e quindi chiama il salvataggio metodo e attendere in modo asincrono.

Si può fare la stessa cosa usando un metodo.

Answer 3

Come sull'utilizzo ContinueWith:

var tasks = new List<Task>(); 

for(var item in items) 
{ 
    var task = dbAccess.DeleteAsync(item.id) 
      .ContinueWith(antecedent => dbAccess.SaveAsync(item)) 
      .Unwrap(); 

    tasks.Add(task); 
} 

await Task.WhenAll(tasks);