L'exécution Asynchrone en Boucle Foreach C# async attendent

J'ai du mal à saisir le concept de base de c# async attendent.

Définition Simple serait, Async-Attendent est une partie .Net de la concurrence, qui peut être utilisé pour faire de multiples IO appels, et dans le processus, et non des déchets les Fils, qui sont destinés à des opérations informatiques. Comme son appel à la Base de données, Web services, Réseau des appels, des e /s de Fichier, tout ce qui n'a pas besoin d'un courant de threads du processus

Dans votre cas actuel, où les cas d'utilisation est:

1. une itération à travers ses propriétés et de rejoindre les cordes, puis la création d'un nouvel objet
2. finalement, l'ajout d'une liste de trellocards

Ce qui semble être un calcul lié opération, jusqu'à ce que et à moins que vous sont en train de faire un ar, pour moi, il semble que vous traversez un objet de mémoire, dans ce cas, le meilleur choix serait:

1. En parallèle.ForEach, pour paralléliser le traitement des souvenirs, mais vous devez faire attention à des conditions de Course, comme une donnée de la mémoire peut être consulté par plusieurs threads, donc il corruption spécialement au cours d'une opération d'écriture, au moins dans le code actuel, l'utilisation de la Thread safe collection comme ConcurrentBag de System.Collections.Concurrent espace de noms, ou qui jamais de costume le cas d'utilisation au lieu de List<TrelloCard>, ou vous pouvez envisager la suite de Thread-safe liste

Veuillez également noter que, dans le cas où vos méthodes ne sont pas par défaut Async, alors vous pouvez les envelopper dans un Task.Run, à await sur, même si cela aurait besoin d'un Thread du pool, mais peut être appelée à l'aide de Async-Await

Parallel.Foreach code pour votre cas d'utilisation (je fais un remplacement direct, il semble y avoir un problème dans votre code, depuis ProcessCards fonction, prend juste objet de la Tâche, mais vous êtes aussi en passant la collection Cards, qui est l'erreur de compilation):

 private List<TrelloCard> ProcessJobs(IQueryable<IGrouping<CardGrouping, Job>> jobs)
    {
        ConcurrentBag<TrelloCard> cards = new ConcurrentBag<TrelloCard>();

        Parallel.ForEach(jobs.ToList(), (job) => 
        {
           card = ProcessCards(job);  //I would like to run multiple instances of the processing
           cards.Add(card); //Once each instance is finshed it adds it to the list
        });

           return cards.ToList();
   }

  private TrelloCard ProcessCards(Job job)
    {
       return new TrelloCard();
    }

jobs.ToList() est tout simplement de perdre la mémoire. C'est déjà IEnumerable peut donc être utilisé dans un foreach.

ProcessCards ne compile pas. Vous avez besoin de quelque chose comme cela

    private Task<TrelloCard> ProcessCards(Job job)
    {
        return Task.Run(() =>
        {
            System.Threading.Thread.Sleep(2000);  //Just for examples sake

            return new TrelloCard();
        });
    }

Maintenant, vous voulez ProcessJobs à

• créer un ProcessCards de tâches pour chaque poste de travail
• d'attente pour toutes les tâches de finition

• retour d'une séquence de TrelloCard

  private async Task<List<TrelloCard>> ProcessJobs(IQueryable<IGrouping<CardGrouping, Job>> jobs)
  {
      return await Task.WhenAll(jobs.Select(ProcessCards));
  }