Cómo programar una tarea para su futura ejecución en la Tarea Biblioteca paralela

Question

¿Existe alguna manera de programar una tarea para su ejecución en el futuro utilizando la Biblioteca de tarea paralela?

Me doy cuenta de que podría hacer esto con los métodos pre-.NET4 como System.Threading.Timer ... sin embargo, si hay una forma TPL para hacer esto prefiero mantenerme dentro del diseño del framework. No puedo encontrar uno sin embargo.

Gracias.

Answer 1

Establezca un temporizador de un disparo que, cuando se dispara, inicia la tarea. Por ejemplo, el siguiente código esperará cinco minutos antes de comenzar la tarea.

TimeSpan TimeToWait = TimeSpan.FromMinutes(5); 
Timer t = new Timer((s) => 
    { 
     // start the task here 
    }, null, TimeToWait, TimeSpan.FromMilliseconds(-1)); 

El TimeSpan.FromMilliseconds(-1) hace que el temporizador de un one-shot en lugar de un temporizador periódico.

Answer 2

Esta característica se introdujo en el Async CTP, que ahora se ha incorporado a .NET 4.5. Hacerlo de la siguiente manera no bloquea el hilo, sino que devuelve una tarea que se ejecutará en el futuro.

Task<MyType> new_task = Task.Delay(TimeSpan.FromMinutes(5)) 
          .ContinueWith<MyType>(/*...*/); 

(Si se utiliza el antiguo libera asíncrono, utiliza la clase estática en lugar de TaskExTask)

Answer 3

Puede escribir su propia función RunDelayed. Esto requiere un retraso y una función para ejecutar después de que se complete la demora.

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

utilizar de esta manera:

public void UseRunDelayed() 
    { 
     var task = RunDelayed(500,() => "Hello"); 
     task.ContinueWith(t => Console.WriteLine(t.Result)); 
    }