ユニットテストコード。ContinueWith（）

Question

はので、私はいくつかのコード

Task.Factory.StartNew(() => this.listener.Start()).ContinueWith(
        (task) => 
         { 
          if (task.IsCompleted) 
          { 
           this.status = WorkerStatus.Started; 
           this.RaiseStatusChanged(); 
           this.LogInformationMessage("Worker Started."); 
          } 
         }); 

を持っている（namley this.listener.Start（ ））。問題は、ContinueWithを呼び出す前にテストが実行を終了することです。私がコードをステップ実行する余分な遅延のため、私はそれをうまく呼び出すデバッグするとき。

別のアセンブリのテストコードから、私のテストがアサートする前にコードが実行されていることを確認するにはどうしたらいいですか？

私はちょうどThread.Sleepを使うことができました...しかし、これは本当にハックのようなものです。

私はThread.Joinのタスクバージョンを探していますね。

Answer 1

は、次のことを考えてみましょう：

public class SomeClass 
{ 
    public void Foo() 
    { 
     var a = new Random().Next(); 
    } 
} 

public class MyUnitTest 
{ 
    public void MyTestMethod() 
    { 
     var target = new SomeClass();   
     target.Foo(); // What to assert, what is the result?.. 
    } 
} 

aに割り当てられた値とは何ですか？結果がメソッドFoo()（戻り値、パブリックプロパティ、イベントなど）の外に返されない限り、あなたは知ることができません。

「coordinating the actions of threads for a predictable outcome」の処理は、Synchronizationと呼ばれます。あなたのケースでは、最も簡単な解決策の

一つはTaskクラスのインスタンスを返すためにあるかもしれないし、そのWait()メソッドを使用します。

var task = Task.Factory.StartNew(() => Method1()) 
    .ContinueWith(() => Method2()); 

​​は継続を作成するため、最初のタスクを待つ必要がありませんこと対象タスクが完了（MSDN）非同期に実行されます。私はDの容易な、まだ実用的な方法があるとは思わない

task.Wait(); 

Answer 2

処理が終了したときに通知する方法がある場合（そのStatusChangedイベントのハンドラを追加できますか？）、ManualResetEventを使用して、妥当なタイムアウトで待機します。タイムアウトが切れた場合はテストに失敗し、それ以外の場合はアサーションを実行します。

など。

var waitHandle = new ManualResetEvent(false); 
sut.StatusChanged += (s, e) => waitHandle.Set(); 

sut.DoStuff(); 

Assert.IsTrue(waitHandle.WaitOne(someTimeout), "timeout expired"); 
// do asserts here 

Answer 3

ContinueWith()コールの前に初期タスクが完了したかどうかにかかわらず、継続タスクは実行されます。私は次の点を確認しました：

// Task immediately exits 
var task = Task.Factory.StartNew(() => { }); 

Thread.Sleep(100); 

// Continuation on already-completed task 
task.ContinueWith(t => { MessageBox.Show("!"); }); 

さらにデバッグしてください。多分、あなたの仕事は失敗しているでしょう。

Answer 4

これをする。私は今すぐ同じ問題に遭遇し、Thread.Sleep（X）は問題を回避するための最も単純な（あまりエレガントではない）方法です。

私が検討した唯一の解決策は、Test.Factory.StartNew（）呼び出しをテストの擬似的なインターフェイスの背後に隠して、テストシナリオでタスクの実際の実行を完全に取り除くことですインタフェースメソッドが呼び出されることを期待します。

public interface ITaskWrapper 
{ 
    void TaskMethod(); 
} 

そして、あなたの具体的な実装：たとえば

public class MyTask : ITaskWrapper 
{ 
    public void TaskMethod() 
    { 
     Task.Factory.StartNew(() => DoSomeWork()); 
    } 
} 

それからちょうど模擬テスト方法でITaskWrapperとTaskMethodに期待を設定すると呼ばれています。

Answer 5

Reactive Extensionsを使用するテスト中のコードで非同期プロセスを処理する場合、1つの方法はTestSchedulerを使用することです。 TestSchedulerは時間内に前に移動し、細かく処理されたタスクなどを排除できます。テスト対象のコードでは、TestSchedulerインスタンスを提供するISchedulerを使用できます。その後、実際にスリープしたり、待ったり、同期したりすることなく、時間を操作できます。このアプローチの改良点はLee Campbell's ISchedulerProviderです。

コードでTask.Factory.StartNewの代わりにObservable.Startを使用する場合は、ユニットテストでTestSchedulerを使用して、スケジュールされたすべてのタスクをプッシュすることができます。

//Task.Factory.StartNew(() => DoSomething()) 
// .ContinueWith(t => DoSomethingElse()) 
Observable.Start(() => DoSomething(), schedulerProvider.ThreadPool) 
      .ToTask() 
      .ContinueWith(t => DoSomethingElse()) 

とあなたのユニットテストで：

例えば、テスト対象のコードはこのような何かを見ることができる