класс ConditionVariable

Родитель:: Объект

ConditionVariable объекты дополняют класс Mutex. Используя переменные состояния, можно приостановить выполнение в середине критической секции, пока ресурс не станет доступным.

Пример:

mutex = Mutex.new
resource = ConditionVariable.new

a = Thread.new {
   mutex.synchronize {
     # Thread 'a' now needs the resource
     resource.wait(mutex)
     # 'a' can now have the resource
   }
}

b = Thread.new {
   mutex.synchronize {
     # Thread 'b' has finished using the resource
     resource.signal
   }
}

Публичные методы класса

new() Показать исходный код

static VALUE
rb_condvar_initialize(VALUE self)
{
    struct rb_condvar *cv = condvar_ptr(self);
    list_head_init(&cv->waitq);
    return self;
}

Создаёт новый экземпляр переменной состояния.

Публичные методы экземпляра

broadcast() Показать исходный код

static VALUE
rb_condvar_broadcast(VALUE self)
{
    struct rb_condvar *cv = condvar_ptr(self);
    wakeup_all(&cv->waitq);
    return self;
}

Разбуждает все потоки, ожидающие этого блокировки.

signal() Показать исходный код

static VALUE
rb_condvar_signal(VALUE self)
{
    struct rb_condvar *cv = condvar_ptr(self);
    wakeup_one(&cv->waitq);
    return self;
}

Разбуждает первый поток в очереди, ожидающий этой блокировки.

wait(mutex, timeout=nil) Показать исходный код

static VALUE
rb_condvar_wait(int argc, VALUE *argv, VALUE self)
{
    struct rb_condvar *cv = condvar_ptr(self);
    struct sleep_call args;
    struct sync_waiter w;

    rb_scan_args(argc, argv, "11", &args.mutex, &args.timeout);

    w.th = GET_THREAD();
    list_add_tail(&cv->waitq, &w.node);
    rb_ensure(do_sleep, (VALUE)&args, delete_from_waitq, (VALUE)&w);

    return self;
}

Освобождает блокировку, удерживаемую в mutex и ожидает; повторно приобретает блокировку при пробуждении.

Если задано timeout, этот метод возвращает после того, как прошло timeout секунд, даже если ни один другой поток не передаёт сигнал.

Ruby Core © 1993–2017 Yukihiro Matsumoto
Licensed under the Ruby License.
Ruby Standard Library © contributors
Licensed under their own licenses.