cómo crear no-duplicados ConcurrentQueue?

Question

Necesito una colección concurent que no permita duplicados (para usar en BlockingCollection como Productor/Consumidor). No necesito un orden estricto de elementos. De otra parte quiero minimizar el tiempo máximo de elemento "en vivo" en la colección. Es decir. la colección no debe ser LIFO, idealmente debe ser FIFO.

Bueno, yo diría que necesito ConcurrentQueue sin duplicados permitidos, pero ConcurrentBag sin duplicados también podría funcionar.

¿Por qué C# no contiene nada de eso y probablemente alguien ya lo haya creado?

Esta pregunta es resultado de mi pregunta anterior What type of IProducerConsumerCollection<T> to use for my task?

Answer 1

Bueno, si usted quiere tener estrictamente no hay duplicados, es necesario 'conjuntos'. Por ejemplo, NHibernate usa Iesi.Collections para proporcionar dicha funcionalidad. Tomando Iesi, puede construir su propia funcionalidad en torno a las clases proporcionadas 'Set' (DictionarySet, HashSet, SortedSet). Fuente: http://www.codeproject.com/KB/recipes/sets.aspx

Answer 2

No hay bibliotecas .Net integradas que combinen este conjunto de reglas para una colección. Tiene tres opciones:

1. Escriba su propia clase de colección
2. Uso dos colecciones: Escribir una clase personalizada que utiliza uno ConcurrentQueue y cualquier colección basada en el Conjunto que se auto-comprobaciones de duplicados; agregar a Ejecutar ejecución y si tiene éxito, agregar a ConcurrentQueue; cada añadir/quitar sumaría a las dos colecciones exitosas cuando
3. Uso ConcurrentQueue pero iterar a través de toda la lista de comprobación de un duplicado

Los dos últimos no son muy eficientes (uno con la memoria, el otro con la CPU, E/S, bloqueo) y son más complicados debido a la necesidad de bloqueo explícito, pero cumplirían la tarea. Serán más rápidos de implementar, pero si las compensaciones no cumplen con sus requisitos, tendrá que ir con la opción n. ° 1.

Answer 3

Puede simplemente usar un ConcurrentQueue y antes de llamar al Enqueue compruebe si los datos están en la cola llamando al método ConcurrentQueue.Contains<>. Supongo que el método de extensión Contains<> está bastante bien optimizado.

EDIT: Como otros han señalado, para que esto funcione sería que tendría que utilizar un mecanismo de bloqueo tales como etc exclusión mutua en torno al método Contains<> y el método Enqueue así:

get mutex 
if not Contains<> 
{ 
    Enqueue 
} 
release mutex