N'Parallèle.ForEach Bloc?

Ne l' .net fonction En parallèle.ForEach bloquer le thread appelant? Je suppose que le comportement est l'un de ces:

  1. Oui, il bloque jusqu'à ce que le plus lent du point de l'exécution de retours.
  2. Non, il ne bloque pas et retourne le contrôle immédiatement. Les éléments à exécuter en parallèle sont effectuées sur les threads d'arrière-plan.

Ou peut-être quelque chose d'autre se passe, quelqu'un sait pour sûr?

Cette question s'est posée lors de la mise en œuvre de cette dans une classe de log:

public class MultipleLoggingService : LoggingServiceBase
{
    private readonly List<LoggingServiceBase> loggingServices;

    public MultipleLoggingService(List<LoggingServiceBase> loggingServices)
    {
        this.loggingServices = loggingServices;
        LogLevelChanged += OnLogLevelChanged;
    }

    private void OnLogLevelChanged(object sender, LogLevelChangedArgs args)
    {
        loggingServices.ForEach(l => l.LogLevel = LogLevel);
    }

    public override LogMessageResponse LogMessage(LogMessageRequest request)
    {
        if (request.LogMessage)
            Parallel.ForEach(loggingServices, l => l.LogMessage(request));

        return new LogMessageResponse{MessageLogged = request.LogMessage};
    }
}

Avis de la LogMessage les appels de méthode de certains autres services de journalisation. J'ai besoin de cette partie de retourner immédiatement, afin de ne pas bloquer le thread appelant.

Mise à jour: Basé sur les commentaires des autres (nous avons confirmé le comportement est #1). Donc, j'ai pris des conseils pour utiliser le Tâche bibliothèque et réécrit la boucle comme ceci:

          if (request.LogMessage)
            foreach (var loggingService in loggingServices)
                Task.Factory.StartNew(() => loggingService.LogMessage(request));
InformationsquelleAutor Paul Fryer | 2012-04-14
  1. 57

    Numéro 1 est correct; Parallel.ForEach ne pas revenir jusqu'à ce que la boucle est terminée. Si vous ne voulez pas que votre comportement, vous pouvez simplement exécuter votre boucle comme un Task et l'exécuter sur un autre thread.

    • Merci pour l'astuce! Auriez-vous un petit extrait de code sur la façon d'utiliser "Tâche" dans ce contexte? Merci, Paul
    • t = Tâche.TaskFactory.StartNew(() => {/* en Parallèle.Pour va ici */});
    • Techniquement, le thread appelant est utilisé dans la boucle parallèle. Il n'est donc pas "gaspillé" juste le blocage de la boucle, il est utilisé comme l'un des threads de travail.
    InformationsquelleAutor Gabe
  2. 10

    Re votre mise à jour, StartNew normale dans un foreach() :

    Cela peut ne pas être la plus optimale pour les grandes collections, et vous n'avez pas de point pour gérer les erreurs.

    Votre loggingServices n'a probablement pas tenir des milliers d'articles, mais le errorhandling reste un point .

    Considérer:

    Task.Factory.StartNew(() => 
{
   try
   {
        Parallel.ForEach(loggingServices, l => l.LogMessage(request));
   }
   catch(SomeException ex)
   {
       //at least try to log it ...
   }
});
    • Ah, bon point. Je vais devoir réfléchir un peu, si le service d'enregistrement échoue, comment faire pour enregistrer l'erreur 🙂
    InformationsquelleAutor Henk Holterman