Программирование на языке Ruby
Шрифт:
sleep rand(0)
puts "#{n}: (...играет...)"
sleep rand(0)
puts "#{n}: Я закончил."
@music.synchronize do
@violins_free += 1
@violin.signal if @violins_free == 1
@bows_free += 1
@bow.signal if @bows_free == 1
end
end
end
threads = []
3.times {|i| threads << Thread.new { musician(i) } }
threads.each {|t| t.join }
Мы
13.2.5. Другие способы синхронизации
Еще один механизм синхронизации - это монитор, который в Ruby реализован в библиотеке
monitor.rb
. Это более развитый по сравнению с мьютексом механизм, основное отличие состоит в том, что захваты одного и того же мьютекса не могут быть вложенными, а монитора — могут. Тривиальный случай возникновения такой ситуации вряд ли возможен. В самом деле, кто станет писать такой код:
@mutex = Mutex.new
@mutex.synchronize do
@mutex.synchronize do
#...
end
end
Но нечто подобное может произойти в сложной программе (или при рекурсивном вызове метода). Какова бы ни была причина, последствием будет тупиковая ситуация. Уход от нее — одно из достоинств модуля-примеси
Monitor
.
@mutex = Mutex.new
def some_method
@mutex.synchronize do
#...
some_other_method # Тупиковая ситуация!
end
end
def some_other_method
@mutex.synchronize do
#...
end
end
Модуль-примесь
Monitor
обычно применяется для расширения объекта. Для создания условной переменной предназначен метод new_cond
. Класс
ConditionVariable
в библиотеке monitor.rb
дополнен по сравнению с определением в библиотеке thread
. У него есть методы wait_until
и wait_while
, которые блокируют поток в ожидании выполнения условия. Кроме того, возможен тайм-аут при ожидании, поскольку у
wait
имеется параметр timeout
, равный количеству секунд (по умолчанию nil
). Поскольку примеры работы с потоками у нас кончаются, то в листинге 13.5 мы предлагаем реализацию классов
Queue
и SizedQueue
с помощью монитора. Код приводится с разрешения автора, Шуго Маэда (Shugo Maeda). Листинг 13.5. Реализация класса Queue с помощью монитора
# Автор: Shugo Maeda
require 'monitor'
class Queue
def initialize
@que = []
@monitor = Monitor.new
@empty_cond = @monitor.new_cond
end
def enq(obj)
@monitor.synchronize do
@que.push(obj)
@empty_cond.signal
end
end
def deq
@monitor.synchronize do
while @que.empty?
@empty_cond.wait
end
return @que.shift
end
end
end
class SizedQueue < Queue
attr :max
def initialize(max)
super
@max = max
@full_cond = @monitor.new_cond
end
def enq(obj)
@monitor.synchronize do
while @que.length >= @max
@full_cond.wait
end
super(obj)
end
end
def deq
@monitor.synchronize do
obj = super
if @que.length < @max
@full_cond.signal
end
return obj
end
end
def max=(max)
@monitor.synchronize do
@max = max
Поделиться:
Популярные книги
АН (цикл 11 книг)
Аномальный наследник
Фантастика:
фэнтези
героическая фантастика
попаданцы
аниме
5.75
рейтинг книги
Наследник
4.00
рейтинг книги
Неучтенный элемент. Том 6
6. Антимаг. Вне системы
Фантастика:
фэнтези
5.25
рейтинг книги
Теплица (сборник)
Фантастика:
научная фантастика
5.00
рейтинг книги
Ночь с Ангелом
Проза:
современная проза
7.43
рейтинг книги
Рядовой. Назад в СССР. Книга 1
1. Второй шанс
Фантастика:
попаданцы
альтернативная история
5.00
рейтинг книги
Электрические тела
Детективы:
прочие детективы
6.60
рейтинг книги
Как разнообразить себе жизнь
Любовные романы:
любовно-фантастические романы
5.00
рейтинг книги
Тихие ночи
2. Глэрд
Фантастика:
фэнтези
боевая фантастика
попаданцы
5.00
рейтинг книги
Мое ходячее несчастье
2. Прекрасные
Любовные романы:
современные любовные романы
9.36
рейтинг книги
Одинокая леди
Детективы:
триллеры
боевики
7.57
рейтинг книги
Ликвидатор
8.12
рейтинг книги
Место под солнцем
Старинная литература:
прочая старинная литература
6.00
рейтинг книги
Княжна с тараканами
6. Любимица фортуны Степанида Козлова
Детективы:
иронические детективы
8.67