class Thread::Mutex

Родительский класс:: Object

Thread::Mutex реализует простой семафор, который можно использовать для координации доступа к общим данным из нескольких одновременно работающих потоков.

Пример:

semaphore = Thread::Mutex.new

a = Thread.new {
  semaphore.synchronize {
    # access shared resource
  }
}

b = Thread.new {
  semaphore.synchronize {
    # access shared resource
  }
}

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

Thread::Mutex.new → mutex Показать исходный код

static VALUE
mutex_initialize(VALUE self)
{
    return self;
}

Создаёт новый объект Mutex

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

lock → self Показать исходный код

VALUE
rb_mutex_lock(VALUE self)
{
    return do_mutex_lock(self, 1);
}

Пытается захватить блокировку и ждёт, если она недоступна. Вызывает исключение ThreadError, если mutex заблокирован текущим потоком.

locked? → true or false Показать исходный код

VALUE
rb_mutex_locked_p(VALUE self)
{
    rb_mutex_t *mutex = mutex_ptr(self);

    return RBOOL(locked_p(mutex));
}

Возвращает true, если эта блокировка в данный момент захвачена каким-либо потоком.

owned? → true or false Показать исходный код

VALUE
rb_mutex_owned_p(VALUE self)
{
    rb_fiber_t *fiber = GET_EC()->fiber_ptr;
    rb_mutex_t *mutex = mutex_ptr(self);

    return mutex_owned_p(fiber, mutex);
}

Возвращает true, если эта блокировка в данный момент захвачена текущим потоком.

sleep(timeout = nil) → number or nil Показать исходный код

static VALUE
mutex_sleep(int argc, VALUE *argv, VALUE self)
{
    VALUE timeout;

    timeout = rb_check_arity(argc, 0, 1) ? argv[0] : Qnil;
    return rb_mutex_sleep(self, timeout);
}

Освобождает блокировку и приостанавливает выполнение на timeout секунд, если это значение задано и не равно nil, или на неопределённое время. Вызывает исключение ThreadError, если mutex не был заблокирован текущим потоком.

После пробуждения поток попытается снова захватить блокировку.

Обратите внимание, что этот метод может пробудить поток и без явного вызова Thread#wakeup. Например, при получении сигнала и в других случаях.

Возвращает время сна в секундах, если поток был разбужен, или nil при истечении времени ожидания.

synchronize { ... } → result of the block Показать исходный код

static VALUE
rb_mutex_synchronize_m(VALUE self)
{
    if (!rb_block_given_p()) {
        rb_raise(rb_eThreadError, "must be called with a block");
    }

    return rb_mutex_synchronize(self, rb_yield, Qundef);
}

Захватывает блокировку, выполняет блок и освобождает блокировку после завершения блока. См. пример в описании Thread::Mutex.

try_lock → true or false Показать исходный код

VALUE
rb_mutex_trylock(VALUE self)
{
    rb_mutex_t *mutex = mutex_ptr(self);

    if (mutex->fiber == 0) {
        RUBY_DEBUG_LOG("%p ok", mutex);

        rb_fiber_t *fiber = GET_EC()->fiber_ptr;
        rb_thread_t *th = GET_THREAD();

        mutex_locked(th, fiber, self);
        return Qtrue;
    }
    else {
        RUBY_DEBUG_LOG("%p ng", mutex);
        return Qfalse;
    }
}

Пытается захватить блокировку и немедленно возвращает управление. Возвращает true, если блокировка была получена.

unlock → self Показать исходный код

VALUE
rb_mutex_unlock(VALUE self)
{
    const char *err;
    rb_mutex_t *mutex = mutex_ptr(self);
    rb_thread_t *th = GET_THREAD();

    err = rb_mutex_unlock_th(mutex, th, GET_EC()->fiber_ptr);
    if (err) rb_raise(rb_eThreadError, "%s", err);

    return self;
}

Освобождает блокировку. Вызывает исключение ThreadError, если mutex не был заблокирован текущим потоком.

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