C# attend des sorties de processus sans exception

Question

J'ai un scénario où je dois exécuter la liste des étudiants en parallèle/indépendamment une fois que j'ai la liste des étudiants. Cependant quand je cours ceux avec le code un peu suivant, le programme se termine sans compléter correctement.

public async Task ProcessStudents() 
{ 
    var students = await GetStudentsAsync().ConfigureAwait(false); 
    ProcessSingleStudent(students); 
} 

private static ProcessSingleStudent(IEnumerable<StudentModel> students) 
{ 
    students.ForEach(async student => 
    { 
     await ValidateSingleStudentAsync(student).ConfigureAwait(false); 
    } 
} 

private async Task ValidateSingleStudentAsync(StudentModel student) 
{ 
    //Do some validations here 
    if(validate) 
    { 
     var updated = await UpdateStudentAsync(student).configureAwait(false); //<== This cause issue 
    } 
} 

Comme je vois UpdateStudentAsync causant problème, que si aller avec F10 cette méthode ne retourne rien et arrête application de la console. Même j'ai mis tous les appels try-catch Je n'ai rien trouvé. Si j'interviens dans chaque point de débogage, j'obtiens le résultat attendu.

Impossible de comprendre où se situe le problème.

Answer 1

Votre ProcessSingleStudent n'attend pas les résultats de chaque appel dans foreach. Ainsi, il se termine après itérer

Vous voulez quelque chose comme ceci: https://stackoverflow.com/a/15136833/8302901

Answer 2

Rappelez-vous que async-est contagieuse ou await méthode ProcessSingleStudent n'est pas lui-même async, il est synchrone. Qu'est-ce que vous avez besoin est quelque chose comme

private async Task ProcessSingleStudent(IEnumerable<StudentModel> students) 
{ 
    await students.ForEach(async student => 
    { 
     await ValidateSingleStudentAsync(student).ConfigureAwait(false); 
    }).ConfigureAwait(false) 
} 

Mais cela est impossible (il ne compile pas) sans un peu d'aide d'une bibliothèque nommée AsyncEnumerator.

Le code devient

private async Task ProcessSingleStudent(IEnumerable<StudentModel> students) 
    { 
     await students.ParallelForEachAsync(async student => 
     { 
      await ValidateSingleStudentAsync(student).ConfigureAwait(false); 
     }, 
     maxDegreeOfParalellism: 30, 
     cancellationToken: null, 
     breakLoopOnException: true 
     ).ConfigureAwait(false) 
    }