외부 메서드 호출시 작업 스케줄링

Question

다음과 같은 확장 프로그램을 사용하여 작업에 대한 시간 제한을 설정할 수 있습니다. 나는 내가 의도 한 결과를 얻을 다음을 사용하여 작업을 호출 할 때

private async Task<string> TestTask(PageData page) 
{ 
    await Task.Delay(TimeSpan.FromSeconds(10)); 
    return "teststring"; 
} 

:

public static async Task<T> TimeoutAfter<T>(this Task<T> task, TimeSpan timeSpan, string message = null) 
{ 
    if (task == await Task.WhenAny(task, Task.Delay(timeSpan))) 
     return await task; 
    else 
    { 
     throw new TimeoutException(message); 
    } 
} 

나는 다음과 같은 작업을해야합니다. 나는 데 발행

var teststring = await TestTask() 
       .TimeoutAfter(TimeSpan.FromSeconds(5), "timeout message"); 

내가 (는 C++의 CLR 클래스 라이브러리이 경우) 외부 라이브러리의 메서드를 호출 할 때, TimeoutAfter 내부의 코드는()에 도달하지 못했다되고 작업이 시간 초과 적이 있다는 것입니다. Task.Factory.StartNew() (아래)를 사용하여이 문제를 해결할 수 있으며, 장기 실행 태스크에 콜백을 전달하고 주 태스크의 실행 전에 Task.Delay 태스크를 작성하지만이 작업은 확장으로 작동하지 않습니다. .

private async Task<T> Timeout<T>(Func<Task<T>> taskFunc) 
{ 
    var taskWait = Task.Delay(TimeSpan.FromSeconds(15)); 
    var task = Task.Factory.StartNew(() => taskFunc()); 

    if (task == await Task.WhenAny(task, taskWait)) 
     return await (await task); 
    else 
    { 
     throw new TimeoutException("timeout"); 
    } 
} 

TimeoutAfter()의 코드가 확장되는 작업에 특정 내용이있을 때만 실행되는 이유는 무엇입니까? 어떤 일이 발생하지 않도록 확장 프로그램에 어떤 기능을 추가 할 수 있습니까?

Answer 1

내 생각에 확장 방법을 시도 할 때 작업을 시작하지 않는다고 생각합니다.

Task은 완전히 비동기이며 코드는 must be started입니다. 작업을 시작하는 한 가지 방법은 공장에서 시도한 것처럼 StartNew를 사용하는 것입니다.

그러나 Start 메서드를 호출 할 수도 있습니다. 경고해야 할 것은 시작이 이미 시작되었거나 이미 끝난 경우 Start를 호출 할 때 예외가 발생한다는 것입니다.

그래서, 당신의 해결책이 될 수 있다고 생각 :

public static async Task<T> TimeoutAfter<T>(this Task<T> task, TimeSpan timeSpan, string message = null) 
{ 
    if(task.Status != TaskStatus.Running && task.Status != TaskStatus.RanToCompletion){ 
     task.Start(); 
    } 
    if (task == await Task.WhenAny(task, Task.Delay(timeSpan))) 
     return await task; 
    else 
    { 
     throw new TimeoutException(message); 
    } 
}