Cách lên lịch một nhiệm vụ để thực hiện trong Thư viện song song nhiệm vụ

Question

Có cách nào để lên lịch một Tác vụ để thực hiện trong tương lai bằng cách sử dụng Thư viện song song tác vụ không?

Tôi nhận ra mình có thể làm điều này với các phương thức tiền .NET4 chẳng hạn như System.Threading.Timer ... tuy nhiên nếu có cách TPL để thực hiện điều này, tôi muốn nằm trong thiết kế của khung công tác. Tôi không thể tìm thấy một tuy nhiên.

Cảm ơn bạn.

Answer 1

Đặt bộ hẹn giờ một lần, khi được kích hoạt, khởi động tác vụ. Ví dụ: mã bên dưới sẽ đợi năm phút trước khi bắt đầu tác vụ.

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

TimeSpan.FromMilliseconds(-1) làm hẹn giờ một lần chứ không phải định kỳ.

Answer 2

Tính năng này được giới thiệu trong Async CTP, hiện đã được cuộn vào .NET 4.5. Làm như sau không chặn luồng, nhưng trả về một Tác vụ sẽ thực hiện trong tương lai.

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

(Nếu sử dụng async cũ phát hành, sử dụng lớp tĩnh TaskEx thay vì Task)

Answer 3

Bạn có thể viết hàm RunDelayed của riêng bạn. Điều này có một sự chậm trễ và một chức năng để chạy sau khi sự chậm trễ hoàn thành.

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

Sử dụng nó như thế này:

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