question de verrouillage de base en C#

Question

Les classes:

public class SomeCollection 
{ 
    public void IteratorReset() 
    { 
     index = -1; 
    } 

    public bool IteratorNext() 
    { 
     index++; 
     return index < Count; 
    } 

    public int Count 
    { 
     get 
     { 
      return floatCollection.Count; 
     } 
    } 

    public float CurrentValue 
    { 
     get 
     { 
     return floatCollection[index]; 
     } 
    } 

    public int CurrentIndex 
    { 
     get 
     { 
     return intCollection[index]; 
     } 
    } 
} 

classe qui tient référence à 'SomeCollection':

public class ThreadUnsafeClass 
{  
    public SomeCollection CollectionObj 
    { 
     get 
     { 
      return collectionObj; 
     }    
    }  
} 

Classes ClassA, ClassB et ClassC contiennent la boucle suivante qui itère sur CollectionObj:

for (threadUnsafeClass.CollectionObj.IteratorReset(); threadUnsafeClass.CollectionObj.IteratorNext();) 
{ 
    int currentIntIndex = threadUnsafeClass.CollectionObj.CurrentIndex; 
    float currentfloatValue = threadUnsafeClass.CollectionObj.CurrentValue; 

    // ...  
} 

Puisque je suis seulement lecture CollectionObj dans les 3 classes, j'utilise multithreading pour l'accélération, mais je ne suis pas sûr de savoir comment faire appliquer la sécurité des threads. J'ai ajouté un verrou dans ThreadUnsafeClass lors de la récupération de CollectionObj, mais l'application génère une exception hors de portée.

Toute aide est appréciée.

Merci!

Answer 1

Vous lisez uniquement la propriété CollectionObj, mais vous mouvez alors l'objet auquel la valeur fait référence. Voir ce bit:

for (threadUnsafeClass.CollectionObj.IteratorReset(); 
    threadUnsafeClass.CollectionObj.IteratorNext();) 

Les deux IteratorReset et IteratorNext muter SomeCollection en changeant la valeur de index. Fondamentalement, vous ne pouvez pas le faire en toute sécurité avec votre code actuel. Plusieurs threads peuvent tous appeler IteratorNext() en même temps, par exemple. Le premier appel renvoie true, mais avant que ce thread ne puisse lire les valeurs, les autres threads rendent l'index invalide. Pourquoi utilisez-vous la collection pour l'itération? Généralement, vous implémentez IEnumerable<T> et renvoyez un nouvel objet dans GetEnumerator. De cette façon, des threads différents pourraient chacun obtenir un objet différent représentant "leur" curseur sur la même collection. Ils pourraient tous itérater dessus, et tous voir toutes les valeurs.

Answer 2

Le verrouillage de la propriété CollectionObj n'aidera pas. Un problème possible est que tous les 3 threads appellent IteratorReset(), ce qui définit l'index à -1. Imaginez le scénario où A commence la boucle for, et arrive à la première ligne de la boucle avant d'être interrompue. Maintenant B arrive et appelle IteratorReset(), puis est interrompu pour laisser A s'exécuter à nouveau. Thread A exécute la propriété CurrentIndex, qui utilise en interne index = -1 en raison de B en cours d'exécution. Boom, exception hors de portée.

Il existe d'autres façons de générer de mauvais résultats, mais c'est probablement le plus facile à voir. Est-ce que l'intention est que chacun des trois fils passe par chaque élément? Ou attendez-vous que A, B et C divisent le travail (comme une file d'attente de consommateurs)?

Answer 3

L'objet SomeCollection est référencé par chacune des trois classes A, B et C, chacune tentant d'incrémenter l'index interne, provoquant l'erreur (les erreurs). Cela dit, vous devriez être en mesure de lire des objets dans un tableau à partir de plusieurs threads avec quelque chose comme ce qui suit:

public static object[] sharedList = new object[]{1,2,3,4,5}; 
public void Worker() 
{ 
    int localSum=0; 
    for(int i=0; i<sharedList.length; i++){ 
     localSum += (int)sharedList[i]; 
    } 
} 

L'important est que chaque fil conservera son propre emplacement dans le tableau, contrairement à la collectionObj .