Interlocked Classe

Definição

Fornece operações atómicas para variáveis que são partilhadas por múltiplos threads.

public ref class Interlocked abstract sealed
public ref class Interlocked sealed
public static class Interlocked
public sealed class Interlocked
type Interlocked = class
Public Class Interlocked
Public NotInheritable Class Interlocked
Herança
Interlocked

Exemplos

O seguinte exemplo de código mostra um mecanismo de bloqueio de recursos seguro para threads.

using System;
using System.Threading;

namespace InterlockedExchange_Example
{
    class MyInterlockedExchangeExampleClass
    {
        //0 for false, 1 for true.
        private static int usingResource = 0;

        private const int numThreadIterations = 5;
        private const int numThreads = 10;

        static void Main()
        {
            Thread myThread;
            Random rnd = new Random();

            for(int i = 0; i < numThreads; i++)
            {
                myThread = new Thread(new ThreadStart(MyThreadProc));
                myThread.Name = String.Format("Thread{0}", i + 1);
            
                //Wait a random amount of time before starting next thread.
                Thread.Sleep(rnd.Next(0, 1000));
                myThread.Start();
            }
        }

        private static void MyThreadProc()
        {
            for(int i = 0; i < numThreadIterations; i++)
            {
                UseResource();
            
                //Wait 1 second before next attempt.
                Thread.Sleep(1000);
            }
        }

        //A simple method that denies reentrancy.
        static bool UseResource()
        {
            //0 indicates that the method is not in use.
            if(0 == Interlocked.Exchange(ref usingResource, 1))
            {
                Console.WriteLine("{0} acquired the lock", Thread.CurrentThread.Name);
            
                //Code to access a resource that is not thread safe would go here.
            
                //Simulate some work
                Thread.Sleep(500);

                Console.WriteLine("{0} exiting lock", Thread.CurrentThread.Name);
            
                //Release the lock
                Interlocked.Exchange(ref usingResource, 0);
                return true;
            }
            else
            {
                Console.WriteLine("   {0} was denied the lock", Thread.CurrentThread.Name);
                return false;
            }
        }
    }
}
Imports System.Threading

Namespace InterlockedExchange_Example
    Class MyInterlockedExchangeExampleClass
        '0 for false, 1 for true.
        Private Shared usingResource As Integer = 0

        Private Const numThreadIterations As Integer = 5
        Private Const numThreads As Integer = 10

        <MTAThread> _
        Shared Sub Main()
            Dim myThread As Thread
            Dim rnd As New Random()

            Dim i As Integer
            For i = 0 To numThreads - 1
                myThread = New Thread(AddressOf MyThreadProc)
                myThread.Name = String.Format("Thread{0}", i + 1)

                'Wait a random amount of time before starting next thread.
                Thread.Sleep(rnd.Next(0, 1000))
                myThread.Start()
            Next i
        End Sub

        Private Shared Sub MyThreadProc()
            Dim i As Integer
            For i = 0 To numThreadIterations - 1
                UseResource()

                'Wait 1 second before next attempt.
                Thread.Sleep(1000)
            Next i
        End Sub 

        'A simple method that denies reentrancy.
        Shared Function UseResource() As Boolean
            '0 indicates that the method is not in use.
            If 0 = Interlocked.Exchange(usingResource, 1) Then
                Console.WriteLine("{0} acquired the lock", Thread.CurrentThread.Name)

                'Code to access a resource that is not thread safe would go here.
                'Simulate some work
                Thread.Sleep(500)

                Console.WriteLine("{0} exiting lock", Thread.CurrentThread.Name)

                'Release the lock
                Interlocked.Exchange(usingResource, 0)
                Return True
            Else
                Console.WriteLine("   {0} was denied the lock", Thread.CurrentThread.Name)
                Return False
            End If
        End Function 
    End Class 
End Namespace

Observações

Os métodos desta classe ajudam a proteger contra erros que podem ocorrer quando o escalonador muda de contexto enquanto uma thread atualiza uma variável que pode ser acedida por outras threads, ou quando duas threads estão a executar simultaneamente em processadores separados. Os membros desta turma não fazem exceções.

Os Increment métodos e Decrement incrementam ou diminuem uma variável e armazenam o valor resultante numa única operação. Na maioria dos computadores, incrementar uma variável não é uma operação atómica, exigindo os seguintes passos:

  1. Carrega um valor de uma variável de instância num registo.
  2. Incremente ou diminua o valor.
  3. Armazene o valor na variável de instância.

Se não usar Increment e Decrement, uma thread pode ser preemptada após executar os dois primeiros passos. Outro thread pode então executar os três passos. Quando a primeira thread retoma a execução, sobreescreve o valor na variável de instância, e perde-se o efeito do incremento ou decremento realizado pela segunda thread.

O Add método soma atomicamente um valor inteiro a uma variável inteira e devolve o novo valor da variável.

O método Exchange troca atomicamente os valores das variáveis especificadas. O CompareExchange método combina duas operações: comparar dois valores e armazenar um terceiro valor numa das variáveis, com base no resultado da comparação. As operações de comparação e troca são realizadas como uma operação atómica.

Certifique-se de que qualquer acesso de escrita ou leitura a uma variável partilhada é atómico. Caso contrário, os dados podem estar corrompidos ou o valor carregado pode estar incorreto.

Métodos

Name Description
Add(Int32, Int32)

Soma dois inteiros de 32 bits e substitui o primeiro inteiro pela soma, como uma operação atómica.

Add(Int64, Int64)

Soma dois inteiros de 64 bits e substitui o primeiro inteiro pela soma, como uma operação atómica.

CompareExchange(Double, Double, Double)

Compara dois números de ponto flutuante de dupla precisão para igualdade e, se forem iguais, substitui o primeiro valor, como uma operação atómica.

CompareExchange(Int32, Int32, Int32)

Compara dois inteiros assinados de 32 bits para igualdade e, se forem iguais, substitui o primeiro valor, como uma operação atómica.

CompareExchange(Int64, Int64, Int64)

Compara dois inteiros assinados de 64 bits para igualdade e, se forem iguais, substitui o primeiro valor, como uma operação atómica.

CompareExchange(IntPtr, IntPtr, IntPtr)

Compara dois inteiros assinados de tamanho nativo para igualdade e, se forem iguais, substitui o primeiro, como uma operação atómica.

CompareExchange(Object, Object, Object)

Compara dois objetos para igualdade de referência e, se forem iguais, substitui o primeiro objeto, como uma operação atómica.

CompareExchange(Single, Single, Single)

Compara dois números de ponto flutuante de precisão simples para igualdade e, se forem iguais, substitui o primeiro valor, como uma operação atómica.

CompareExchange<T>(T, T, T)

Compara duas instâncias do tipo T especificado para igualdade de referência e, se forem iguais, substitui a primeira, como operação atómica.

Decrement(Int32)

Diminui uma variável especificada e armazena o resultado como uma operação atómica.

Decrement(Int64)

Diminui a variável especificada e armazena o resultado como uma operação atómica.

Exchange(Double, Double)

Define um número de ponto flutuante de dupla precisão para um valor especificado e devolve o valor original, como uma operação atómica.

Exchange(Int32, Int32)

Define um inteiro assinado de 32 bits para um valor especificado e devolve o valor original como uma operação atómica.

Exchange(Int64, Int64)

Define um inteiro assinado de 64 bits para um valor especificado e devolve o valor original, como uma operação atómica.

Exchange(IntPtr, IntPtr)

Define um inteiro com assinatura de tamanho nativo a um valor especificado e devolve o valor original, como uma operação atómica.

Exchange(Object, Object)

Define um objeto para um valor especificado e devolve uma referência ao objeto original, como uma operação atómica.

Exchange(Single, Single)

Define um número de ponto flutuante de precisão simples para um valor especificado e devolve o valor original, como uma operação atómica.

Exchange<T>(T, T)

Define uma variável do tipo T especificado para um valor especificado e devolve o valor original, como uma operação atómica.

Increment(Int32)

Incrementa uma variável especificada e armazena o resultado, como uma operação atómica.

Increment(Int64)

Incrementa uma variável especificada e armazena o resultado, como uma operação atómica.

MemoryBarrier()

Sincroniza o acesso à memória da seguinte forma: O processador que executa a thread atual não pode reordenar instruções de forma a que a memória acede antes da chamada para MemoryBarrier() executar após os acessos à memória que seguem a chamada para MemoryBarrier().

MemoryBarrierProcessWide()

Fornece uma barreira de memória em todo o processo que garante que as leituras e escritas de qualquer CPU não possam atravessar essa barreira.

Read(Int64)

Devolve um valor de 64 bits, carregado como uma operação atómica.

SpeculationBarrier()

Define uma barreira de memória que bloqueia a execução especulativa para além deste ponto até que as leituras e escritas pendentes estejam concluídas.

Aplica-se a

Segurança de Thread

Este tipo é seguro para fios.

Ver também