Еще одним классом, связанным с синхронизацией, является класс 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();
}
}
Рассматривавшиеся ранее классы синхронизации, в том числе Semaphore и AutoResetEvent, были доступны в среде .NET Framework, начиная с версии 1.1.
Таким образом, эти классы образуют основу поддержки синхронизации в среде .NET Framework. Но после выпуска версии .NET Framework 4.0 появился ряд новых альтернатив этим классам синхронизации. Все они перечисляются ниже.
Класс - Назначение
Barrier - Вынуждает потоки ожидать появления всех остальных потоков в указанной точке, называемой
CountdownEvent - Выдает сигнал, когда обратный отсчет завершается
ManualResetEventSlim - Это упрощенный вариант класса ManualResetEvent
semaphoreslim - Это упрощенный вариант класса Semaphore
Если вам понятно, как пользоваться основными классами синхронизации, описанными ранее в этой главе, то у вас не должно возникнуть затруднений при использовании их новых альтернатив и дополнений.
Иногда поток полезно прервать до его нормального завершения. Например, отладчику может понадобиться прервать вышедший из-под контроля поток. После прерывания поток удаляется из системы и не может быть начат снова.
Для прерывания потока до его нормального завершения служит метод Thread.Abort(). Ниже приведена простейшая форма этого метода.
public void Abort()
