Введение в распределенные

Листинг 4.2. Функция работы с маркером.
void AssignPrivilege() {
/* Функция работы с маркером */

if (Holder == self && !Using && !Q.empty()) {

/* Выборка первого элемента из очереди Q */ Holder = Q.front();

Q.pop();
Asked = false;

/* Если первый элемент self, процесс входит в КС */

/* иначе передает маркер процессу c ID в Holder */ if (Holder == self) {
Using = true;
/* вход в КС */
}
else {
/* отправка TOKEN процессу c ID в Holder */
}
}
}
Листинг 4.3. Функция отправки запроса на получение маркера.
void MakeRequest() {
/* Функция отправки запроса на получение маркера */

if (Holder != self && !Asked && !Q.empty()) {

/* отправка REQUEST процессу c ID в Holder */ Asked = true;
}
}
Функция работы с маркером. Отправлять маркер другому
процессу или использовать его для входа в КС может только процесс, для которого одновременно выполняются следующие условия: (1) Holder = self,

2. 
   Using = false, (3) очередь Q не пуста.
   

Если значение self не является первым элементом в очереди Q, то процесс, владеющий маркером, пересылает его соседнему процессу, идентификатор которого находится во главе очереди Q. При этом он удаляет этот элемент из Q, т.к. передача маркера по соответствующему запросу становится выполненной, и обновляет значение своей переменной Holder таким образом, чтобы оно указывало на нового обладателя маркера. Ситуация, когда в очереди Q процесса, владеющего маркером, первым элементом является self, возможна, например, когда этот процесс только что получил сообщение TOKEN от своего соседа. В этом случае он получает право войти в КС, удалив при этом первый элемент со значением self из начала очереди, и присвоив переменной Using значение true. Переменная Asked устанавливается в значение false, т.к. при передаче маркера процесс может не отправлять сообщение REQUEST процессу, на который указывает новое значение его переменной Holder.