Barrier Klasse

Definition

Namespace:

System.Threading

Assembly:

System.Threading.dll

Assembly:

System.dll

Assembly:

netstandard.dll

Ermöglicht es mehreren Aufgaben, parallel über mehrere Phasen gemeinsam an einem Algorithmus zu arbeiten.

C#

public class Barrier : IDisposable

C#

[System.Runtime.InteropServices.ComVisible(false)]
public class Barrier : IDisposable

Vererbung

Object

Barrier

Attribute

ComVisibleAttribute

Implementiert

IDisposable

Beispiele

Im folgenden Beispiel wird gezeigt, wie Sie eine Barriere verwenden:

C#

using System;
using System.Threading;
using System.Threading.Tasks;

class BarrierDemo
{
    // Demonstrates:
    //      Barrier constructor with post-phase action
    //      Barrier.AddParticipants()
    //      Barrier.RemoveParticipant()
    //      Barrier.SignalAndWait(), incl. a BarrierPostPhaseException being thrown
    static void BarrierSample()
    {
        int count = 0;

        // Create a barrier with three participants
        // Provide a post-phase action that will print out certain information
        // And the third time through, it will throw an exception
        Barrier barrier = new Barrier(3, (b) =>
        {
            Console.WriteLine("Post-Phase action: count={0}, phase={1}", count, b.CurrentPhaseNumber);
            if (b.CurrentPhaseNumber == 2) throw new Exception("D'oh!");
        });

        // Nope -- changed my mind.  Let's make it five participants.
        barrier.AddParticipants(2);

        // Nope -- let's settle on four participants.
        barrier.RemoveParticipant();

        // This is the logic run by all participants
        Action action = () =>
        {
            Interlocked.Increment(ref count);
            barrier.SignalAndWait(); // during the post-phase action, count should be 4 and phase should be 0
            Interlocked.Increment(ref count);
            barrier.SignalAndWait(); // during the post-phase action, count should be 8 and phase should be 1

            // The third time, SignalAndWait() will throw an exception and all participants will see it
            Interlocked.Increment(ref count);
            try
            {
                barrier.SignalAndWait();
            }
            catch (BarrierPostPhaseException bppe)
            {
                Console.WriteLine("Caught BarrierPostPhaseException: {0}", bppe.Message);
            }

            // The fourth time should be hunky-dory
            Interlocked.Increment(ref count);
            barrier.SignalAndWait(); // during the post-phase action, count should be 16 and phase should be 3
        };

        // Now launch 4 parallel actions to serve as 4 participants
        Parallel.Invoke(action, action, action, action);

        // This (5 participants) would cause an exception:
        // Parallel.Invoke(action, action, action, action, action);
        //      "System.InvalidOperationException: The number of threads using the barrier
        //      exceeded the total number of registered participants."

        // It's good form to Dispose() a barrier when you're done with it.
        barrier.Dispose();
    }
}

Hinweise

Eine Gruppe von Aufgaben arbeitet zusammen, indem sie durch eine Reihe von Phasen wechseln, in denen jede in der Gruppe signalisiert, dass sie in einer bestimmten Phase angekommen Barrier ist und implizit darauf wartet, dass alle anderen ankommen. Dasselbe Barrier kann für mehrere Phasen verwendet werden.

Konstruktoren

Barrier(Int32)	Initialisiert eine neue Instanz der Barrier-Klasse.
Barrier(Int32, Action<Barrier>)	Initialisiert eine neue Instanz der Barrier-Klasse.

Eigenschaften

CurrentPhaseNumber	Ruft die Nummer der aktuellen Phase der Grenze ab.
ParticipantCount	Ruft die Gesamtanzahl von Teilnehmern für die Grenze ab.
ParticipantsRemaining	Ruft die Anzahl von Teilnehmern für die Grenze ab, die in der aktuellen Phase noch nicht signalisiert haben.

Methoden

AddParticipant()	Benachrichtigt Barrier über das Vorhandensein eines weiteren Teilnehmers.
AddParticipants(Int32)	Benachrichtigt Barrier über das Vorhandensein weiterer Teilnehmer.
Dispose()	Gibt alle von der aktuellen Instanz der Barrier-Klasse verwendeten Ressourcen frei.
Dispose(Boolean)	Gibt die von Barrier verwendeten nicht verwalteten Ressourcen und optional die verwalteten Ressourcen frei.
Equals(Object)	Bestimmt, ob das angegebene Objekt gleich dem aktuellen Objekt ist. (Geerbt von Object)
GetHashCode()	Fungiert als Standardhashfunktion. (Geerbt von Object)
GetType()	Ruft den Type der aktuellen Instanz ab. (Geerbt von Object)
MemberwiseClone()	Erstellt eine flache Kopie des aktuellen Object. (Geerbt von Object)
RemoveParticipant()	Benachrichtigt Barrier, dass ein Teilnehmer nicht mehr vorhanden ist.
RemoveParticipants(Int32)	Benachrichtigt Barrier über die geringere Anzahl von Teilnehmern.
SignalAndWait()	Signalisiert, dass ein Teilnehmer die Barriere erreicht hat und darauf wartet, dass alle anderen Teilnehmer die Barriere ebenfalls erreichen.
SignalAndWait(CancellationToken)	Signalisiert, dass ein Teilnehmer die Barriere erreicht hat und darauf wartet, dass alle anderen Teilnehmer die Barriere erreichen. Dabei wird ein Abbruchtoken überwacht.
SignalAndWait(Int32)	Signalisiert, dass ein Teilnehmer die Barriere erreicht hat und darauf wartet, dass alle anderen Teilnehmer die Barriere ebenfalls erreichen. Dabei wird eine 32-Bit-Ganzzahl mit Vorzeichen zum Messen des Timeouts verwendet.
SignalAndWait(Int32, CancellationToken)	Signalisiert, dass ein Teilnehmer die Barriere erreicht hat und darauf wartet, dass alle anderen Teilnehmer die Barriere ebenfalls erreichen. Dabei wird eine 32-Bit-Ganzzahl mit Vorzeichen zum Messen des Timeouts verwendet und ein Abbruchtoken berücksichtigt.
SignalAndWait(TimeSpan)	Signalisiert, dass ein Teilnehmer die Barriere erreicht hat und darauf wartet, dass alle anderen Teilnehmer die Barriere ebenfalls erreichen. Dabei wird das Zeitintervall mit einem TimeSpan-Objekt gemessen.
SignalAndWait(TimeSpan, CancellationToken)	Signalisiert, dass ein Teilnehmer die Barriere erreicht hat und darauf wartet, dass alle anderen Teilnehmer die Barriere ebenfalls erreichen. Dabei wird das Zeitintervall mit einem TimeSpan-Objekt gemessen und ein Abbruchtoken berücksichtigt.
ToString()	Gibt eine Zeichenfolge zurück, die das aktuelle Objekt darstellt. (Geerbt von Object)

Gilt für

Threadsicherheit

Alle öffentlichen und geschützten Elemente Barrier sind threadsicher und können gleichzeitig von mehreren Threads verwendet werden, mit Ausnahme von "Dispose", die nur verwendet werden müssen, wenn alle anderen Vorgänge auf dem Barrier abgeschlossenen Vorgang abgeschlossen sind.

Siehe auch

• Barriere
• Gewusst wie: Synchronisieren gleichzeitiger Vorgänge mit einer Barriere