Расписание задач при вызове внешнего метода

Question

У меня есть следующее расширение, которое позволяет мне заставить тайм-аут выполнять задачу.

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); 
    } 
} 

У меня есть следующая задача:

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

Когда я называю задачу, используя следующий я получаю желаемый результат.

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

я выдаю я имею что когда я вызываю метод во внешней библиотеке (в данном случае с ++ 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

Я думаю, что ваша главная проблема заключается в том, что вы просто не запускаете свою задачу, когда пытаетесь использовать метод расширения.

A 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); 
    } 
}