Jak mogę przetestować, czy implementacje są synchroniczne lub asynchroniczne, gdy jest to wymagane?

Question

Próbuję pisać testy jednostkowe wokół niestandardowej implementacji SynchronizationContext.

Dwie ważne operacje na tej klasy są Send i Post, gdzie Send wywołuje delegata synchronicznie i Post wywołuje delegata asynchronicznie.

Chciałbym napisać testy jednostkowe, aby zweryfikować to zachowanie, że delegaci zostali wykonani synchronicznie lub asynchronicznie. Nie chcę, aby testy polegały na opóźnieniach w przypadku powodzenia, ponieważ sztucznie przedłuża on testy (ale rozsądne jest, aby awarie powodowały opóźnienie) w wykonaniu.

Początkowo rozważaliśmy użyciu Zadania sygnalizować wykonanie delegat:

var tcs = new TaskCompletionSource<object>(); 

var context = new CustomSynchronizationContext(); 

context.Send((state) => tcs.SetResult(null), null); 

// Task should already be completed! 
Assert.IsTrue(this.tcs.Task.IsCompleted); 

Jednak to nie zapewnia pełnomocnik został nie wykonywane asynchronicznie bardzo szybko, zanim zawodnik testowy mógł kontynuować.

Jak mogę zorganizować test całym kontekście, aby Send bloki zakończeniu delegata i Post nie robi, ale że delegaci są zarówno powoływać?

Answer 1

Zawierające mój pomysł:

var mainThreadId = Thread.ManagedThreadId; 
var sendThreadId; 
context.Send((state) => sendThreadId = Thread.ManagedThreadId); 
Assert.AreEqual(mainThreadId, sendThreadId); 

nie wiem, czy to faktycznie działa, trzeba sprawdzić.

Answer 2

Uważam, że można to osiągnąć za pomocą pary ManualResetEvents. Używając poniższego kodu, spowolnienie występuje tylko wtedy, gdy testy się nie powiodły (liczby są dość wysokie i prawdopodobnie można je bezpiecznie zmniejszyć). Pomysł polega na tym, że potwierdzamy kolejność, w której muszą zajść rzeczy, które mogą się zdarzyć tylko wtedy, gdy zablokujemy lub nie zablokujemy.

Dla synchronicznego testu:

var incall = new ManualResetEvent(false); 
var unblock = new ManualResetEvent(false); 
var context = new CustomSynchronizationContext(); 
var t = Task.Run(() => context.Send(state => 
{ 
    incall.Set(); 
    unblock.WaitOne(5000); 
}, null)); 
Assert.IsTrue(incall.WaitOne(1000)); 
Assert.IsFalse(t.Wait(10)); 
unblock.Set(); 
Assert.IsTrue(t.Wait(1000)); 

do testu Async:

var incall = new ManualResetEvent(false); 
var unblock = new ManualResetEvent(false); 
var context = new CustomSynchronizationContext(); 
var t = Task.Run(() =>context.Post(state => 
{ 
    incall.Set(); 
    unblock.WaitOne(5000); 
}, null)); 
Assert.IsTrue(incall.WaitOne(1000)); 
Assert.IsTrue(t.Wait(1000)); //This will timeout if unblock is blocking completion of the task 
unblock.Set();