Страница 407 из 502

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

Шилдт Герберт

Ниже приведены общие формы методов Pulse() и PulseAll():

public static void Pulse(object obj)

public static void PulseAll(object obj)

где obj обозначает освобождаемый объект.

Если методы Wait(),Pulse() и PulseAll() вызываются из кода, находящегося за пределами синхронизированного кода, например из блока lock, то генерируется исключение SynchronizationLockException.

Для того чтобы стало понятнее назначение методов Wait() и Pulse(), рассмотрим пример программы, имитирующей тиканье часов и отображающей этот процесс на экране словами "тик" и "так". Для этой цели в программе создается класс TickTock, содержащий два следующих метода: Tick() и Тоск(). Метод Tick() выводит на экран слово "тик", а метод Тоск() — слово "так". Для запуска часов далее в программе создаются два потока: один из них вызывает метод Tick(), а другой — метод Тоск(). Преследуемая в данном случае цель состоит в том, чтобы оба потока выполнялись, поочередно выводя на экран слова "тик" и "так", из которых образуется повторяющийся ряд "тик-так", имитирующий ход часов.

//Использовать методы Wait() и Pulse() для иммитации

//тиканья часов

using System;

using System.Threading;

class TickTock {

object lockOn = new object();

public void Tick(bool ru

lock(lockOn) {

if(!ru

Monitor.Pulse(lockOn); // уведомить любые ожидающие потоки

return;

}

Console.Write("тик ");

Monitor.Pulse(lockOn); // разрешить выполнение метода Tock()

Monitor.Wait(lockOn); // ожидать завершения метода Tock()

}

public void Tock(bool ru

lock(lockOn) {

if(!ru

Monitor.Pulse(lockOn); // уведомить любые ожидающие потоки

return;

}

Console.WriteLine("так");

Monitor.Pulse(lockOn); // разрешить выполнение метода Tick()

Monitor.Wait(lockOn); // ожидать завершения метода Tick()

}

}

class MyThread {

public Thread Thrd;

TickTock ttOb;

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

public MyThread(string name, TickTock tt) {

Thrd = new Thread(this.Run);

ttOb = tt;

Thrd.Name = name;

Thrd.Start();

}

// Начать выполнение нового потока,

void Run() {

if(Thrd.Name == "Tick") {

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

ttOb.Tick(true);

ttOb.Tick(false) ;

}

else {

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

ttOb.Tock(true);

ttOb.Tock(false);

}

}

class TickingClock {

static void Main() {

TickTock tt = new TickTock();

MyThread mt1 = new MyThread("Tick", tt);

MyThread mt2 = new MyThread("Tock", tt);