Barrier Classe

Definição

Namespace:

System.Threading

Assembly:

System.Threading.dll

Assembly:

System.dll

Assembly:

netstandard.dll

Permite que várias tarefas trabalhem de forma colaborativa em um algoritmo em paralelo por meio de várias fases.

C#

public class Barrier : IDisposable

C#

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

Herança

Object

Barrier

Atributos

ComVisibleAttribute

Implementações

IDisposable

Exemplos

O exemplo a seguir mostra como usar uma barreira:

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

Comentários

Um grupo de tarefas coopera movendo-se através de uma série de fases, onde cada uma no grupo sinaliza que chegou à Barrier determinada fase e aguarda implicitamente a chegada de todas as outras. O mesmo Barrier pode ser usado para várias fases.

Construtores

Barrier(Int32)	Inicializa uma nova instância da classe Barrier.
Barrier(Int32, Action<Barrier>)	Inicializa uma nova instância da classe Barrier.

Propriedades

CurrentPhaseNumber	Obtém o número da fase atual da barreira.
ParticipantCount	Obtém o número total de participantes na barreira.
ParticipantsRemaining	Obtém o número de participantes na barreira que ainda não foram sinalizados na fase atual.

Métodos

AddParticipant()	Notifica o Barrier de que haverá um participante adicional.
AddParticipants(Int32)	Notifica o Barrier de que haverá participantes adicionais.
Dispose()	Libera todos os recursos usados pela instância atual da classe Barrier.
Dispose(Boolean)	Libera os recursos não gerenciados usados pelo Barrier e opcionalmente libera os recursos gerenciados.
Equals(Object)	Determina se o objeto especificado é igual ao objeto atual. (Herdado de Object)
GetHashCode()	Serve como a função de hash padrão. (Herdado de Object)
GetType()	Obtém o Type da instância atual. (Herdado de Object)
MemberwiseClone()	Cria uma cópia superficial do Object atual. (Herdado de Object)
RemoveParticipant()	Notifica o Barrier de que haverá um participante a menos.
RemoveParticipants(Int32)	Notifica o Barrier de que haverá menos participantes.
SignalAndWait()	Indica que um participante atingiu a barreira e aguarda até que todos os outros participantes atinjam a barreira também.
SignalAndWait(CancellationToken)	Indica que um participante atingiu a barreira e aguarda até que todos os outros participantes atinjam a barreira, enquanto observa um token de cancelamento.
SignalAndWait(Int32)	Indica que um participante atingiu a barreira e aguarda até que todos os outros participantes atinjam a barreira também, usando um inteiro com sinal de 32 bits para medir o tempo limite.
SignalAndWait(Int32, CancellationToken)	Indica que um participante atingiu a barreira e aguarda até que todos os outros participantes atinjam a barreira também, usando um inteiro com sinal de 32 bits para medir o tempo limite, enquanto observa um token de cancelamento.
SignalAndWait(TimeSpan)	Indica que um participante atingiu a barreira e aguarda até que todos os outros participantes atinjam a barreira também, usando um objeto TimeSpan para medir o intervalo de tempo.
SignalAndWait(TimeSpan, CancellationToken)	Indica que um participante atingiu a barreira e aguarda até que todos os outros participantes atinjam a barreira também, usando um objeto TimeSpan para medir o intervalo de tempo, enquanto observa um token de cancelamento.
ToString()	Retorna uma cadeia de caracteres que representa o objeto atual. (Herdado de Object)

Aplica-se a

Acesso thread-safe

Todos os membros públicos e protegidos Barrier são thread-safe e podem ser usados simultaneamente de vários threads, com exceção de Dispose, que só deve ser usado quando todas as outras operações no Barrier ter concluído.

Confira também

• Barreira
• Como sincronizar operações simultâneas com uma barreira