Синхронизация процессов

Семафор имеет некоторое начальное значение и две операции P и V. Операция P уменьшает на 1 значение семафора, если он не равен 0. Иначе процесс ожидает (с блокировкой или без нее), пока значение семафора не станет отличным от 0. V - операция увеличивает на 1 значение семафора. Операции проверки и изменения значения переменной являются неделимыми. В нашей модели эти операции (с циклическим ожиданием) выглядят следующим образом (Заметим, что явное переключение процессов - в данном случае вещь чисто техническая и не принципиальная, предназначенная для более быстрой реакции нужных процессов по произошедшим событиям).

void P(int *sem)
{while(1)
{ RUN++; // " Критическая секция"

if (*sem!=0) // Уменьшить ненулевой семафор и выйти

{ (*sem)--; RUN--; return; }
else // Повторить (с переключение процессов)

{ RUN--; NOCLOCK++;
geninterrupt(TIMVEC);


}
}}

void V(int *sem) // Увеличить семафор

{ RUN++; (*sem)++; RUN--; // Выйти (с переключением процессов)

NOCLOCK++; geninterrupt(TIMVEC);
}
В заключение приведем пример решения классической задачи " поставщик - потребитель" , взаимодействующих через общий циклический буфер .

&#35define N 5 // Размер буфера

&#35define TW 18*2 // Время " работы" потребителя

int EMPTY=N, // Семафор " БУФЕР ПОЛОН"

FULL=0, // Семафор " БУФЕР ПУСТ"

SEMBUF=1; // Семафор " ОПЕРАЦИЯ С БУФЕРОМ"

int fst=0,lst=0; // Циклическая очередь

char BUFF[N];

void consume() // Процесс - потребитель

{ while(1)
{ WAIT(TW); // Процесс " работает"

P(&#38FULL); // P(Буфер не пуст)

P(&#38SEMBUF); // P(Операция с буфером )

char s=BUFF[fst]; // Получить из буфера

fst=(fst+1)%N; // и вывести

textbackground(BLUE);
putch(s);
V(&#38SEMBUF); // V(Операция с буфером )

V(&#38EMPTY); // V(Буфер не полон )

}}

void produce() // Процесс - производитель

{ while(1)
{
if (kbhit()) { // Если есть ввод

char c=getch();
textbackground(BLACK);
putch(c);
if (c=='\r') STOP++;
P(&#38EMPTY); // P(Буфер не полон )

P(&#38SEMBUF); // P(Операция с буфером )

textbackground(MAGENTA);
putch(c);
BUFF[lst]=c; // Поместить в буфер

lst=(lst+1)%N;
V(&#38SEMBUF); // V(Операция с буфером )

V(&#38FULL); // V(Буфер не пуст )

}}}