C# 4.0: полное руководство

Еще одним классом, связанным с синхронизацией, является класс Interlocked. Этот класс служит в качестве альтернативы другим средствам синхронизации, когда требуется только изменить значение общей переменной. Методы, доступные в классе Interlocked, гарантируют, что их действие будет выполняться как единая, непрерываемая операция. Это означает, что никакой синхронизации в данном случае вообще не требуется. В классе Interlocked предоставляются статические методы для сложения двух целых значений, инкрементирования и декрементирования целого значения, сравнения и установки значений объекта, обмена объектами и получения 64-разрядно-го значения. Все эти операции выполняются без прерывания.

В приведенном ниже примере программы демонстрируется применение двух методов из класса Interlocked: Increment() и Decrement(). При этом используются следующие формы обоих методов:

public static int Increment(ref int location)

public static int Decrement(ref int location)

где location — это переменная, которая подлежит инкрементированию или декрементированию.

// Использовать блокируемые операции.

using System;

using System.Threading;

// Общий ресурс,

class SharedRes {

  public static int Count = 0;

}

// В этом потоке переменная SharedRes.Count инкрементируется,

class IncThread {

  public Thread Thrd;

  public IncThread(string name) {

    Thrd = new Thread(this.Run);

    Thrd.Name = name;

    Thrd.Start();

  }

  // Точка входа в поток,

  void Run() {

    for(int i=0; i<5; i++) {

      Interlocked.Increment(ref SharedRes.Count);

      Console.WriteLine(Thrd.Name + " Count = " + SharedRes.Count);

    }

  }

}

// В этом потоке переменная SharedRes.Count декрементируется,

class DecThread {

  public Thread Thrd;

  public DecThread(string name) {

    Thrd = new Thread(this.Run);

    Thrd.Name = name;

    Thrd.Start();

  }

  // Точка входа в поток,

  void Run() {

    for(int i=0; i<5; i++) {

      Interlocked.Decrement(ref SharedRes.Count);

      Console.WriteLine(Thrd.Name + " Count = " + SharedRes.Count);

    }

  }

}

class InterlockedDemo {

  static void Main() {

    // Сконструировать два потока.

    IncThread mt1 = new IncThread("Инкрементирующий Поток");

    DecThread mt2 = new DecThread("Декрементирующий Поток");

    mt1.Thrd.Join();

    mt2.Thrd.Join();

  }

}

Классы синхронизации, внедренные в версии .NET Framework 4.0

Рассматривавшиеся ранее классы синхронизации, в том числе Semaphore и AutoResetEvent, были доступны в среде .NET Framework, начиная с версии 1.1.

Таким образом, эти классы образуют основу поддержки синхронизации в среде .NET Framework. Но после выпуска версии .NET Framework 4.0 появился ряд новых альтернатив этим классам синхронизации. Все они перечисляются ниже.

Класс - Назначение

Barrier - Вынуждает потоки ожидать появления всех остальных потоков в указанной точке, называемой барьерной

CountdownEvent - Выдает сигнал, когда обратный отсчет завершается

ManualResetEventSlim - Это упрощенный вариант класса ManualResetEvent

semaphoreslim - Это упрощенный вариант класса Semaphore

Если вам понятно, как пользоваться основными классами синхронизации, описанными ранее в этой главе, то у вас не должно возникнуть затруднений при использовании их новых альтернатив и дополнений.

Прерывание потока

Иногда поток полезно прервать до его нормального завершения. Например, отладчику может понадобиться прервать вышедший из-под контроля поток. После прерывания поток удаляется из системы и не может быть начат снова.

Для прерывания потока до его нормального завершения служит метод Thread.Abort(). Ниже приведена простейшая форма этого метода.

public void Abort()