ConcurrentDictionary Pitfall - ¿Están delegadas las fábricas de GetOrAdd y AddOrUpdate sincronizadas?

Question

La documentación de ConcurrentDictionary estado no hace explícita, así que supongo que no podemos esperar que los delegados valueFactory y updateValueFactory tienen su ejecución sincronizada (de GetOrAdd() y AddOrUpdate() las operaciones, respectivamente).

Por lo tanto, creo que no podemos implementar el uso de recursos dentro de ellos que necesitan control concurrente sin implementar manualmente nuestro propio control simultáneo, tal vez simplemente usando [MethodImpl(MethodImplOptions.Synchronized)] sobre los delegados.

¿Estoy en lo cierto? O el hecho de que ConcurrentDictionary es seguro para subprocesos, podemos esperar que las llamadas a estos delegados se sincronicen automáticamente (también a prueba de subprocesos)?

Answer 1

Sí, tiene razón, los delegados de los usuarios no están sincronizados por ConcurrentDictionary. Si necesita sincronizarlos, es su responsabilidad.

El MSDN mismo dice:

Además, aunque todos los métodos de ConcurrentDictionary son compatibles con el proceso, no todos los métodos son atómicas, específicamente GetOrAdd y AddOrUpdate. El delegado de usuario que se pasa a estos métodos es invocado fuera del bloqueo interno del diccionario. (Esto se hace para evitar que el código desconocido de bloquear todas las discusiones.)

See "How to: Add and Remove Items from a ConcurrentDictionary

Esto es porque el ConcurrentDictionary tiene ni idea de lo que el delegado que usted provee hacer o su rendimiento, por lo que si se trató de bloqueo a su alrededor, realmente podría afectar negativamente el rendimiento y arruinar el valor de ConcurrentDictionary.

Por lo tanto, es responsabilidad del usuario sincronizar su delegado si es necesario. El enlace de MSDN anterior en realidad tiene un buen ejemplo de las garantías que hace y no hace.

Answer 2

No solo estos delegados no están sincronizados, sino que ni siquiera se garantiza que sucedan solo una vez. De hecho, pueden ejecutarse varias veces por llamada al AddOrUpdate.

Por ejemplo, el algoritmo para AddOrUpdate se parece a esto.

TValue value; 
do 
{ 
    if (!TryGetValue(...)) 
    { 
    value = addValueFactory(key); 
    if (!TryAddInternal(...)) 
    { 
     continue; 
    } 
    return value; 
    } 
    value = updateValueFactory(key); 
} 
while (!TryUpdate(...)) 
return value; 

Tenga en cuenta dos cosas aquí.

• No hay esfuerzo para sincronizar la ejecución de los delegados.
• Los delegados se pueden ejecutar más de una vez desde que se invocaron dentro de el bucle.

Así que debe asegurarse de hacer dos cosas.

• Proporcione su propia sincronización para los delegados.
• Asegúrese de que sus delegados no tengan ningún efecto secundario que dependa del número de veces que se ejecutan.