класс 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)
{
    rb_execution_context_t *ec = GET_EC();

    struct rb_condvar *cv = condvar_ptr(self);
    struct sleep_call args;

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

    COROUTINE_STACK_LOCAL(struct sync_waiter, w);
    w->self = args.mutex;
    w->th = ec->thread_ptr;
    w->fiber = ec->fiber_ptr;

    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–2020 Yukihiro Matsumoto
Licensed under the Ruby License.
Ruby Standard Library © contributors
Licensed under their own licenses.