Najlepsza praktyka LongRunning Tworzenie zadań

Question

Czy jest to dobry projekt dla wątku tła, który musi zostać uruchomiony przy użyciu interfejsu API Task w .Net 4? Moją jedyną troską jest to, czy chcemy anulować to zadanie, jak bym to zrobił? Wiem, że mogę ustawić ProgramEnding na true, ale wiem, że w interfejsie API zadań jest CancellationToken.

To tylko przykładowa próbka kodu, aby jeden wątek był dodawany do kolekcji, a inny wątek będzie z niego usuwany. Zadanie jest ustawiony jako LongRunning jak to musi być uruchomiony w sposób ciągły, podczas gdy program jest uruchomiony

private void RemoveFromBlockingCollection() 
{ 
    while (!ProgramEnding) 
    { 
     foreach (var x in DataInQueue.GetConsumingEnumerable()) 
     { 
      Console.WriteLine("Task={0}, obj={1}, Thread={2}" 
          , Task.CurrentId, x + " Removed" 
          , Thread.CurrentThread.ManagedThreadId); 
     } 
    } 
} 

private void button1_Click(object sender, EventArgs e) 
{ 
    DataInQueue = new BlockingCollection<string>(); 
    var t9 = Task.Factory.StartNew(RemoveFromBlockingCollection 
           , TaskCreationOptions.LongRunning); 

    for (int i = 0; i < 100; i++) 
    { 
    DataInQueue.Add(i.ToString()); 
    Console.WriteLine("Task={0}, obj={1}, Thread={2}", 
         Task.CurrentId, i + " Added", 
         Thread.CurrentThread.ManagedThreadId); 
    Thread.Sleep(100); 
    } 
    ProgramEnding = true; 
} 

UPDATE: Odkryłem, że mogę usunąć logiczną ProgramEnding i używać DataInQueue.CompleteAdding które który przynieść wątku koniec.

Answer 1

Jak już wspomniano, można użyć Znacznika Anulowania. Zrobić to w ten sposób:

var cancellationTokenSource = new CancellationTokenSource(); 
Task.Factory.StartNew(RemoveFromBlockingCollection 
         , TaskCreationOptions.LongRunning 
         , cancellationTokenSource.Token); 

a później w kodzie, można anulować zadanie z:

cancellationTokenSource.Cancel(); 

W swojej długiej zadania uruchomionego można poprosić token, jeśli odwołanie została wezwana:

if (cancellationTokenSource.Token.IsCancellationRequested)