Есть ли способ запланировать задачу для выполнения в будущем с помощью библиотеки параллельных задач?
Я понимаю, что мог бы сделать это с помощью методов pre-.NET4, таких как System.Threading.Timer... однако, если есть способ TPL сделать это, я бы предпочел остаться в рамках дизайна фреймворка. Однако я не могу найти его.
Спасибо.
Эта функция была представлена в Async CTP, которая теперь включена в .NET 4.5. Выполнение этого следующим образом не блокирует поток, а возвращает задачу, которая будет выполняться в будущем.
Task<MyType> new_task = Task.Delay(TimeSpan.FromMinutes(5))
.ContinueWith<MyType>( /*...*/ );
(При использовании старых выпусков Async используйте статический класс TaskEx вместо Task)
Task.Delay не спит! Как правило, засыпание Task (потока) полностью противоречит цели дизайна и философии System.Threading.Tasks.Task и не рекомендуется. Сон никогда не станет основой встроенного .NET API, такого как Task.Delay; скорее он полагается на планировщик в ядре ОС для создания задачи, которая не выполняется, пока не истечет задержка. Кроме того, Крис предложил await, и в этом случае Delay может вообще не использовать дополнительный поток, так как async/await позволяют отдельным потокам вносить вклад в продвижение нескольких заблокированных операций.
- person Glenn Slayden; 29.11.2017
Task.Delay - это .NET 4.5. Или, говоря иначе, альтернатива в .NET 4, не использующая Sleep. Хотя уже не имеет значения. Уже перешел на .NET 4.6.
- person Milosz Krajewski; 30.11.2017
Вы можете написать свою собственную функцию RunDelayed. Это требует задержки и функции для запуска после завершения задержки.
public static Task<T> RunDelayed<T>(int millisecondsDelay, Func<T> func)
{
if(func == null)
{
throw new ArgumentNullException("func");
}
if (millisecondsDelay < 0)
{
throw new ArgumentOutOfRangeException("millisecondsDelay");
}
var taskCompletionSource = new TaskCompletionSource<T>();
var timer = new Timer(self =>
{
((Timer) self).Dispose();
try
{
var result = func();
taskCompletionSource.SetResult(result);
}
catch (Exception exception)
{
taskCompletionSource.SetException(exception);
}
});
timer.Change(millisecondsDelay, millisecondsDelay);
return taskCompletionSource.Task;
}
Используйте это так:
public void UseRunDelayed()
{
var task = RunDelayed(500, () => "Hello");
task.ContinueWith(t => Console.WriteLine(t.Result));
}
Установите одноразовый таймер, который при срабатывании запускает задачу. Например, приведенный ниже код будет ждать пять минут перед запуском задачи.
TimeSpan TimeToWait = TimeSpan.FromMinutes(5);
Timer t = new Timer((s) =>
{
// start the task here
}, null, TimeToWait, TimeSpan.FromMilliseconds(-1));
TimeSpan.FromMilliseconds(-1) делает таймер одноразовым, а не периодическим.
