test unitaire pour la condition de la course

Question

Considérons le code:

class TestClass 
{ 
    private bool _someFlag; 
    private object _sharedObject = new object(); 
    private readonly object _syncObject = new object(); 

    public object Read() 
    { 
     //lock (_syncObject) 
     { 
      _someFlag = false; 
      return _sharedObject; 
     } 
    } 

    public void Write(object obj) 
    { 
     //lock (_syncObject) 
     { 
      _someFlag = true; 
      _sharedObject = obj; 
     } 
    } 
} 

Il a question de condition de course. Lorsque nous appelons Read() certains thread peuvent appeler Write() entre _someFlag = false; et return _sharedObject; lignes. Je vais résoudre le problème par l'opérateur lock. Mais pourriez-vous s'il vous plaît m'aider à tester ce problème de condition de course.

Je ne veux pas changer _someFlag à public à des fins de test ou quelque chose comme ça. Je veux faire quelque chose comme ça:

[Fact] 
public void RaceConditionTest() 
{ 
    var correctObject = new object(); 
    var test = new TestClass(); 

    for (int i = 0; i < 1000; i++) 
    { 
     test.Write(correctObject); 
     var assertTask = Task.Run(() => 
     { 
      var actualObj = test.Read(); 
      Assert.True(object.ReferenceEquals(correctObject, actualObj), $"Failed on {i} iteration"); 
     }); 
     //Thread.Sleep(50); 
     var failTask = Task.Run(() => test.Write(new object())); 

     Task.WaitAll(assertTask, failTask); 
    } 
} 

Mais comment puis-je être sûr que assertTask sera lancé avant failTask? Ou peut-être y a-t-il une autre façon de tester ce cas? Merci d'avance.

Answer 1

moi avons séjourné avec cette approche. Mais toujours à la recherche d'un meilleur moyen ... Ce test échoue sur certaines itérations, mais si vous décommentez les opérateurs lock, le test sera réussi.

class TestClass 
{ 
    private IEventRecorder _eventRecorder; 


    private bool _someFlag; 
    private object _sharedObject = new object(); 
    private readonly object _syncObject = new object(); 

#if DEBUG 
    public void SetEventRecorder(IEventRecorder eventRecorder) => _eventRecorder = eventRecorder; 
#endif 

    public object Read() 
    { 
     //lock (_syncObject) 
     { 
#if DEBUG 
      _eventRecorder?.Record(nameof(Read)); 
#endif 
      _someFlag = false; 
      return _sharedObject; 
     } 
    } 

    public void Write(object obj) 
    { 
     //lock (_syncObject) 
     { 
#if DEBUG 
      _eventRecorder?.Record(nameof(Write)); 
#endif 
      _someFlag = true; 
      _sharedObject = obj; 
     } 
    } 

    public interface IEventRecorder 
    { 
     void Record(string eventName); 
    } 
} 

public class TestClassTests 
{ 
    private class EventRecorder : TestClass.IEventRecorder 
    { 
     private string _events = string.Empty; 

     public void Record(string eventName) => _events += eventName; 

     public string Events => _events; 

     public void Reset() => _events = string.Empty; 
    } 

    [Fact] 
    public void RaceConditionTest() 
    { 
     var correctObject = new object(); 
     var eventRecorder = new EventRecorder(); 
     var test = new TestClass(); 
     test.SetEventRecorder(eventRecorder); 

     for (int i = 0; i < 1000; i++) 
     { 
      test.Write(correctObject); 
      var assertTask = Task.Run(() => 
      { 
       var actualObj = test.Read(); 
       if (eventRecorder.Events.StartsWith("WriteRead")) 
        Assert.True(object.ReferenceEquals(correctObject, actualObj), $"Failed on {i} iteration"); 
      }); 
      var failTask = Task.Run(() => test.Write(new object())); 

      Task.WaitAll(assertTask, failTask); 
      eventRecorder.Reset(); 
     } 
    } 
} 

Answer 2

vous pouvez vérifier si assertTask est en cours d'exécution ou terminé avant de commencer failTask:

while (assertTask.Status != Running && assertTask.Status != RanToCompletion) 
Thread.Sleep(50);