класс Thread::SizedQueue

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

Этот класс представляет очереди с заданной емкостью. Операция добавления может быть заблокирована, если емкость заполнена.

См. Thread::Queue для примера того, как работает Thread::SizedQueue.

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

new(max)

Исходный код

static VALUE
rb_szqueue_initialize(VALUE self, VALUE vmax)
{
    long max;
    struct rb_szqueue *sq = szqueue_ptr(self);

    max = NUM2LONG(vmax);
    if (max <= 0) {
        rb_raise(rb_eArgError, "queue size must be positive");
    }

    RB_OBJ_WRITE(self, szqueue_list(sq), ary_buf_new());
    ccan_list_head_init(szqueue_waitq(sq));
    ccan_list_head_init(szqueue_pushq(sq));
    sq->max = max;

    return self;
}

Создает очередь фиксированной длины с максимальным размером max.

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

<<(object)

Псевдоним для: push

clear ()

Исходный код

static VALUE
rb_szqueue_clear(VALUE self)
{
    struct rb_szqueue *sq = szqueue_ptr(self);

    rb_ary_clear(check_array(self, sq->q.que));
    wakeup_all(szqueue_pushq(sq));
    return self;
}

Удаляет все объекты из очереди.

Исходный код

static VALUE
rb_szqueue_close(VALUE self)
{
    if (!queue_closed_p(self)) {
        struct rb_szqueue *sq = szqueue_ptr(self);

        FL_SET(self, QUEUE_CLOSED);
        wakeup_all(szqueue_waitq(sq));
        wakeup_all(szqueue_pushq(sq));
    }
    return self;
}

Аналогично Thread::Queue#close.

Различие в поведении с ожидающими потоками добавления.

Если есть ожидающие потоки добавления, они прерываются сгенерированием исключения ClosedQueueError(‘очередь закрыта’).

deq

Псевдоним для: pop

empty?

Исходный код

static VALUE
rb_szqueue_empty_p(VALUE self)
{
    struct rb_szqueue *sq = szqueue_ptr(self);

    return RBOOL(queue_length(self, &sq->q) == 0);
}

Возвращает true, если очередь пуста.

enq(object, non_block=false, timeout: nil)

Псевдоним для: push

length

size

Исходный код

static VALUE
rb_szqueue_length(VALUE self)
{
    struct rb_szqueue *sq = szqueue_ptr(self);

    return LONG2NUM(queue_length(self, &sq->q));
}

Возвращает длину очереди.

Также используется псевдоним: size

max ()

Исходный код

static VALUE
rb_szqueue_max_get(VALUE self)
{
    return LONG2NUM(szqueue_ptr(self)->max);
}

Возвращает максимальный размер очереди.

max=(number)

Исходный код

static VALUE
rb_szqueue_max_set(VALUE self, VALUE vmax)
{
    long max = NUM2LONG(vmax);
    long diff = 0;
    struct rb_szqueue *sq = szqueue_ptr(self);

    if (max <= 0) {
        rb_raise(rb_eArgError, "queue size must be positive");
    }
    if (max > sq->max) {
        diff = max - sq->max;
    }
    sq->max = max;
    sync_wakeup(szqueue_pushq(sq), diff);
    return vmax;
}

Устанавливает максимальный размер очереди на заданное значение number.

num_waiting ()

Исходный код

static VALUE
rb_szqueue_num_waiting(VALUE self)
{
    struct rb_szqueue *sq = szqueue_ptr(self);

    return INT2NUM(sq->q.num_waiting + sq->num_waiting_push);
}

Возвращает количество потоков, ожидающих в очереди.

pop(non_block=false, timeout: nil)

Исходный код

# File thread_sync.rb, line 36
def pop(non_block = false, timeout: nil)
  if non_block && timeout
    raise ArgumentError, "can't set a timeout if non_block is enabled"
  end
  Primitive.rb_szqueue_pop(non_block, timeout)
end

Извлекает данные из очереди.

Если очередь пуста, вызывающий поток приостанавливается, пока данные не будут добавлены в очередь. Если non_block истинно, поток не приостанавливается и генерируется исключение ThreadError.

Если прошло timeout секунд, и данные недоступны, возвращается nil. Если timeout равно 0, возвращается значение немедленно.

Также используется псевдоним: deq, shift

push(object, non_block=false, timeout: nil)

Исходный код

# File thread_sync.rb, line 59
def push(object, non_block = false, timeout: nil)
  if non_block && timeout
    raise ArgumentError, "can't set a timeout if non_block is enabled"
  end
  Primitive.rb_szqueue_push(object, non_block, timeout)
end

Добавляет object в очередь.

Если места в очереди нет, поток ожидает освобождения места, если non_block не истинно. Если non_block истинно, поток не приостанавливается и генерируется исключение ThreadError.

Если прошло timeout секунд, и места нет, возвращается nil. Если timeout равно 0, возвращается значение немедленно. В противном случае возвращается self.

Также используется псевдоним: enq, <<

shift

Псевдоним для: pop

length

size

Возвращает длину очереди.

Псевдоним для: length

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