CancellationToken Struktur

Definition

Namespace:

System.Threading

Assemblys:

netstandard.dll, System.Runtime.dll

Quelle:

CancellationToken.cs

Gibt eine Benachrichtigung darüber weiter, dass Vorgänge abgebrochen werden sollen.

C#

public readonly struct CancellationToken : IEquatable<System.Threading.CancellationToken>

Vererbung

Object

ValueType

CancellationToken

Implementiert

IEquatable<CancellationToken>

Beispiele

Im folgenden Beispiel wird ein Zufallszahlengenerator verwendet, um eine Datensammlungsanwendung zu emulieren, die zehn integrale Werte aus elf verschiedenen Instrumenten liest. Der Wert 0 gibt an, dass bei der Messung für ein Instrument ein Fehler aufgetreten ist. In diesem Fall sollte der Vorgang abgebrochen und kein Gesamtmittelwert berechnet werden.

Um den möglichen Abbruch des Vorgangs zu behandeln, instanziiert das Beispiel ein CancellationTokenSource -Objekt, das ein Abbruchtoken generiert, das an ein TaskFactory Objekt übergeben wird. Im Gegenzug übergibt das TaskFactory -Objekt das Abbruchtoken an alle Aufgaben, die für das Sammeln von Messwerten für ein bestimmtes Instrument verantwortlich sind. Die TaskFactory.ContinueWhenAll<TAntecedentResult,TResult>(Task<TAntecedentResult>[], Func<Task<TAntecedentResult>[],TResult>, CancellationToken) -Methode wird aufgerufen, um sicherzustellen, dass der Mittelwert erst berechnet wird, nachdem alle Messwerte erfolgreich erfasst wurden. Wenn eine Aufgabe nicht abgeschlossen wurde, weil sie abgebrochen wurde, löst die TaskFactory.ContinueWhenAll Methode eine Ausnahme aus.

C#

using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;

public class Example
{
   public static void Main()
   {
      // Define the cancellation token.
      CancellationTokenSource source = new CancellationTokenSource();
      CancellationToken token = source.Token;

      Random rnd = new Random();
      Object lockObj = new Object();
      
      List<Task<int[]>> tasks = new List<Task<int[]>>();
      TaskFactory factory = new TaskFactory(token);
      for (int taskCtr = 0; taskCtr <= 10; taskCtr++) {
         int iteration = taskCtr + 1;
         tasks.Add(factory.StartNew( () => {
           int value;
           int[] values = new int[10];
           for (int ctr = 1; ctr <= 10; ctr++) {
              lock (lockObj) {
                 value = rnd.Next(0,101);
              }
              if (value == 0) { 
                 source.Cancel();
                 Console.WriteLine("Cancelling at task {0}", iteration);
                 break;
              }   
              values[ctr-1] = value; 
           }
           return values;
        }, token));   
      }
      try {
         Task<double> fTask = factory.ContinueWhenAll(tasks.ToArray(), 
         (results) => {
            Console.WriteLine("Calculating overall mean...");
            long sum = 0;
            int n = 0; 
            foreach (var t in results) {
               foreach (var r in t.Result) {
                  sum += r;
                  n++;
               }
            }
            return sum/(double) n;
         } , token);
         Console.WriteLine("The mean is {0}.", fTask.Result);
      }   
      catch (AggregateException ae) {
         foreach (Exception e in ae.InnerExceptions) {
            if (e is TaskCanceledException)
               Console.WriteLine("Unable to compute mean: {0}", 
                  ((TaskCanceledException) e).Message);
            else
               Console.WriteLine("Exception: " + e.GetType().Name);
         }
      }
      finally {
         source.Dispose();
      }
   }
}
// Repeated execution of the example produces output like the following:
//       Cancelling at task 5
//       Unable to compute mean: A task was canceled.
//       
//       Cancelling at task 10
//       Unable to compute mean: A task was canceled.
//       
//       Calculating overall mean...
//       The mean is 5.29545454545455.
//       
//       Cancelling at task 4
//       Unable to compute mean: A task was canceled.
//       
//       Cancelling at task 5
//       Unable to compute mean: A task was canceled.
//       
//       Cancelling at task 6
//       Unable to compute mean: A task was canceled.
//       
//       Calculating overall mean...
//       The mean is 4.97363636363636.
//       
//       Cancelling at task 4
//       Unable to compute mean: A task was canceled.
//       
//       Cancelling at task 5
//       Unable to compute mean: A task was canceled.
//       
//       Cancelling at task 4
//       Unable to compute mean: A task was canceled.
//       
//       Calculating overall mean...
//       The mean is 4.86545454545455.

Hinweise

Ein CancellationToken ermöglicht eine kooperative Abbruch zwischen Threads, Arbeitselementen im Threadpool oder Task Objekten. Sie erstellen ein Abbruchtoken, indem Sie ein CancellationTokenSource Objekt instanziieren, das abbruchtoken verwaltet, die aus seiner CancellationTokenSource.Token Eigenschaft abgerufen wurden. Anschließend übergeben Sie das Abbruchtoken an eine beliebige Anzahl von Threads, Aufgaben oder Vorgängen, die eine Kündigungsbenachrichtigung erhalten sollten. Das Token kann nicht zum Initiieren des Abbruchs verwendet werden. Wenn das besitzereigene Objekt aufruft CancellationTokenSource.Cancel, wird die IsCancellationRequested -Eigenschaft für jede Kopie des Abbruchtokens auf truefestgelegt. Die Objekte, die die Benachrichtigung empfangen, können auf jede geeignete Weise reagieren.

Weitere Informationen und Codebeispiele finden Sie unter Abbruch in verwalteten Threads.

Konstruktoren

CancellationToken(Boolean)

Initialisiert das CancellationToken.

Eigenschaften

CanBeCanceled	Ruft einen Wert ab, der angibt, ob der Zustand "abgebrochen" von diesem Token unterstützt wird.
IsCancellationRequested	Ruft einen Wert ab, der angibt, ob für dieses Token ein Abbruch angefordert wurde.
None	Gibt einen leeren CancellationToken-Wert zurück.
WaitHandle	Ruft ein WaitHandle ab, das signalisiert wird, wenn das Token abgebrochen wird.

Methoden

Equals(CancellationToken)	Ermittelt, ob die aktuelle CancellationToken-Instanz gleich dem angegebenen Token ist.
Equals(Object)	Ermittelt, ob die aktuelle CancellationToken-Instanz und die angegebene Object-Instanz gleich sind.
GetHashCode()	Dient als Hashfunktion für eine CancellationToken.
Register(Action, Boolean)	Registriert einen Delegaten, der aufgerufen wird, wenn dieses CancellationToken abgebrochen wird.
Register(Action)	Registriert einen Delegaten, der aufgerufen wird, wenn dieses CancellationToken abgebrochen wird.
Register(Action<Object,CancellationToken>, Object)	Registriert einen Delegaten, der aufgerufen wird, wenn dieser CancellationToken abgebrochen wird.
Register(Action<Object>, Object, Boolean)	Registriert einen Delegaten, der aufgerufen wird, wenn dieses CancellationToken abgebrochen wird.
Register(Action<Object>, Object)	Registriert einen Delegaten, der aufgerufen wird, wenn dieses CancellationToken abgebrochen wird.
ThrowIfCancellationRequested()	Löst eine OperationCanceledException aus, wenn für dieses Token ein Abbruch angefordert wurde.
UnsafeRegister(Action<Object,CancellationToken>, Object)	Registriert einen Delegaten, der aufgerufen wird, wenn dieser CancellationToken abgebrochen wird.
UnsafeRegister(Action<Object>, Object)	Registriert einen Delegaten, der aufgerufen wird, wenn dieses CancellationToken abgebrochen wird.

Operatoren

Equality(CancellationToken, CancellationToken)	Stellt fest, ob zwei CancellationToken-Instanzen gleich sind.
Inequality(CancellationToken, CancellationToken)	Ermittelt, ob zwei CancellationToken-Instanzen ungleich sind.

Gilt für:

Threadsicherheit

Alle öffentlichen und geschützten Member von CancellationToken sind threadsicher und können gleichzeitig von mehreren Threads verwendet werden.

Weitere Informationen

• Abbruch
• Aufgabenabbruch