Rapide et Meilleur Producteur/consommateur file d'attente de la technique BlockingCollection vs simultanées de la File d'attente

Im de l'utilisation de Générique.La file d'attente en C# 3.0 et d'un Moniteur.Entrez,attendre la sortie pour attendre avant de consommer de la file d'attente (en attente de l'élément à être mis en file d'attente). Maintenant je suis passer au C# 4.

Quelqu'un peut-il me suggérer qui est rapide et le meilleur en particulier pour éviter les verrous..

BlockingCollection vs concurrentQueue ou toute autre chose...

Note. Je ne veux pas limiter mon producteur

Merci d'avance..

InformationsquelleAutor C-va | 2011-02-15
  1. 110

    BlockingCollection et ConcurrentQueue sont là précisément pour cette raison. Je doute que vous trouverez quelque chose de mieux, ou plus simple à utiliser. Parallel extensions de l'équipe savent de quoi ils parlent 🙂

    Juste une vérification rapide sur les versions si - vous êtes certainement à l'aide .NET 4, non seulement C# 4? (Par exemple, vous pourriez être à l'aide de Visual Studio 2010 et ainsi, C# 4, mais encore le ciblage .NET 3.5, auquel cas vous ne pouviez pas utiliser Parallel Extensions.)

    Vous pouvez aussi lancer des recherches sur Basée Sur Les Tâches Du Modèle Asynchrone, TPL Dataflow et la async/await fonctionnalités de C# 5... de toute évidence, vous ne pouvez pas les utiliser tout de suite, mais il ne fait pas de mal de savoir ce qui est à venir.

    • BlockingCollection et ConcurrentQueue dont l'un est rapide et le meilleur
    • Vous créez un ConcurrentQueue puis l'envelopper dans un BlockingCollection qui coordonne l'Ajout/Prendre les méthodes. (Vous pouvez ensuite laisser gérer la file d'attente complètement - vous de ne pas toucher à la ConcurrentQueue directement vous-même par la suite.)
    • Merci u.. Pls me suggérer BlockingCollection/ConcurrentQueue dont l'un est rapide et le meilleur
    • Avez-vous fait lire mon commentaire? Vous utilisez les deux types ensemble. Créer un ConcurrentQueue, et puis créer un BlockingCollection pour l'envelopper. Ensuite, utilisez la BlockingCollection exclusivement. (En fait, si vous venez de créer un BlockingCollection sans passer quelque chose pour le constructeur, il va créer un ConcurrentQueue pour vous, mais vous devez comprendre ce qui se passe.)
    • Comment Réaliser cette
    • Je ne sais pas quoi vous dire vraiment... je vous ai dit comment le faire deux fois. Avez-vous lu les docs pour BlockingCollection, et l'exemple de là?
    • BlockingCollection<int> bc = new BlockingCollection<int>(); la Tâche t1 = Tâche.Usine.StartNew(() => { bc.Add(1); en colombie-britannique.Add(2); en colombie-britannique.Add(3); en colombie-britannique.CompleteAdding(); }); la Tâche t2 = Tâche.Usine.StartNew(() => { try { while (true) de la Console.WriteLine(colombie-britannique.Prendre()); } } });
    • jon :Dans le code ci-dessus, Va le Prendre() attend si la file d'attente est vide et reprend à retirer automatiquement si un nouvel élément est ajouté (sans l'aide d'attente/signal). Ou j'ai ot utilisation du moniteur.wai,pulseall / ManualResetEvent ?
    • Quelle est la documentation de BlockingCollection.Prenez le dire? (Vous pouvez aussi regarder BlockingCollection.GetConsumingEnumerable()).
    • un élément de la BlockingCollection<T>. Un appel à Prendre peut bloquer jusqu'à ce qu'un élément est disponible pour être enlevé.
    • Exactement. Donc, si la file d'attente est vide, il permet de bloquer jusqu'à ce qu'il y a un élément dans la file d'attente. Le point de l'ensemble de l'aide du type est de vous éviter d'avoir à utiliser d'Attente etc.
    • J'ai eu un peu de confusion qu'il reprend ou pas. C'est pourquoi la répétition dans ma Question. K . Maintenant je suis Clair. Merci beaucoup.
    • Un point sur ConcurrentQueue que je viens de lancer avec un Pro/Con la mise en œuvre... blogs.msdn.com/b/pfxteam/archive/2012/05/08/... n'est Pas très grave si les articles sont de petits... un problème important s'ils sont de grands objets (comme le mien)le
    • Je voudrais +10 ce post si je le pouvais, je le pense vraiment! BTW, un BlockingCollection peut être réitéré à l'aide d'un Parallel.For, qui est similaire à l'utilité d'un PCQ, et éventuellement un peu plus facile (peut-être BEAUCOUP plus facile) pour fouetter le code.
    • BlockingCollection enveloppements ConcurrentQueue par défaut - msdn.microsoft.com/en-us/library/dd267312(v=vs. 110).aspx

    InformationsquelleAutor Jon Skeet