단위 테스트 코드입니다. 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의 Task 버전을 찾고 있다고 생각한다.

Answer 1

는 다음과 같은 고려? 결과가 메소드 Foo() (반환 값, 공용 속성, 이벤트 등) 외부로 반환되지 않는 한 알 수 없습니다.

"coordinating the actions of threads for a predictable outcome"의 프로세스는 Synchronization이라고합니다. 귀하의 경우 가장 쉬운 솔루션

하나는 Task 클래스의 인스턴스를 반환 할 수 있습니다와는 Wait() 방법을 사용하십시오

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

ContinueWith()가 계속 만들기 때문에, 첫 번째 작업을 기다릴 필요가 없습니다 그 대상 작업이 완료 (MSDN) 비동기 적으로 실행 : 나는 D의 쉬운 아직 실용적인 방법이라고 생각하지 않습니다

task.Wait(); 

Answer 2

처리가 끝났을 때 알림을받을 수있는 방법이 있으면 (해당 StatusChanged 이벤트에 대한 처리기를 추가 할 수 있습니까?) ManualResetEvent를 사용하고 적절한 시간 초과로 기다립니다. 시간 초과가 만료 된 경우 테스트에 실패하고, 그렇지 않으면 계속해서 주장을 수행하십시오.

예.

Answer 3

계속 작업은 ContinueWith() 호출 전에 완료되었는지 여부에 관계없이 계속 실행됩니다. 나는 이것을 다음과 같이 두 번 확인했다 :

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

Thread.Sleep(100); 

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

더 디버그. 어쩌면 당신의 임무는 실패 할 것입니다.

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 어떻게 할당됩니다

Answer 4

이러는거야. 지금 당장 같은 문제에 봉착하고 Thread.Sleep (X)는 문제를 해결하는 가장 간단한 방법입니다.

내가 생각했던 유일한 해결책은 테스트에서 모의 ​​할 수있는 인터페이스 뒤에 Task.Factory.StartNew() 호출을 숨기는 것이므로 테스트 시나리오에서 작업의 실제 실행을 완전히 제거합니다. 인터페이스 메소드가 호출 될 것을 기대한다.

public interface ITaskWrapper 
{ 
    void TaskMethod(); 
} 

그리고 당신의 구체적인 구현 : 예를 들어

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

그럼 그냥 모의 테스트 방법 ITaskWrapper 및 TaskMethod에 기대를 설정 호출되고.

Answer 5

Reactive Extensions를 사용하는 테스트중인 코드에서 비동기 프로세스를 처리 할 때 한 가지 방법은 TestScheduler를 사용하는 것입니다. TestScheduler는 시간이 지나면 앞으로 움직일 수 있고, 모든 shceduled 작업 등이 빠져 나갈 수 있습니다. 따라서 테스트중인 코드는 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()) 

및 단위 테스트에서 :

예를 들어, 테스트중인 코드는 다음과 같이 보일 수