類別 Thread::ConditionVariable

ConditionVariable 物件擴充了類別 Mutex。使用條件變數，可以在臨界區的過程中暫停，直到資源可用。

範例

mutex = Thread::Mutex.new
resource = Thread::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);
    ccan_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) 按一下切換來源

釋放 mutex 中持有的鎖定並等待；喚醒時重新取得鎖定。

如果提供 timeout，此方法會在經過 timeout 秒後傳回，即使沒有其他執行緒發出訊號。

傳回 mutex 中已中斷的結果。

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);

    struct sync_waiter sync_waiter = {
        .self = args.mutex,
        .th = ec->thread_ptr,
        .fiber = nonblocking_fiber(ec->fiber_ptr)
    };

    ccan_list_add_tail(&cv->waitq, &sync_waiter.node);
    return rb_ensure(do_sleep, (VALUE)&args, delete_from_waitq, (VALUE)&sync_waiter);
}