class Thread::Queue
Thread::Queue 类实现了多生产者、多消费者的队列。在线程编程中，当需要在多个线程之间安全地交换信息时，它特别有用。Thread::Queue 类实现了所有必需的锁定语义。
该类实现 FIFO（先进先出）类型的队列。在 FIFO 队列中，最先添加的任务最先被检索。
示例
queue = Thread::Queue.new producer = Thread.new do 5.times do |i| sleep rand(i) # simulate expense queue << i puts "#{i} produced" end end consumer = Thread.new do 5.times do |i| value = queue.pop sleep rand(i/2) # simulate expense puts "consumed #{value}" end end consumer.join
Public Class Methods
Source
static VALUE
rb_queue_initialize(int argc, VALUE *argv, VALUE self)
{
VALUE initial;
struct rb_queue *q = queue_ptr(self);
if ((argc = rb_scan_args(argc, argv, "01", &initial)) == 1) {
initial = rb_to_array(initial);
}
RB_OBJ_WRITE(self, queue_list(q), ary_buf_new());
ccan_list_head_init(queue_waitq(q));
if (argc == 1) {
rb_ary_concat(q->que, initial);
}
return self;
}
创建一个新的队列实例，可以选择使用 enumerable 的内容作为其初始状态。
示例
q = Thread::Queue.new #=> #<Thread::Queue:0x00007ff7501110d0> q.empty? #=> true q = Thread::Queue.new([1, 2, 3]) #=> #<Thread::Queue:0x00007ff7500ec500> q.empty? #=> false q.pop #=> 1
Public Instance Methods
Source
static VALUE
rb_queue_clear(VALUE self)
{
struct rb_queue *q = queue_ptr(self);
rb_ary_clear(check_array(self, q->que));
return self;
}
移除队列中的所有对象。
Source
static VALUE
rb_queue_close(VALUE self)
{
struct rb_queue *q = queue_ptr(self);
if (!queue_closed_p(self)) {
FL_SET(self, QUEUE_CLOSED);
wakeup_all(queue_waitq(q));
}
return self;
}
关闭队列。已关闭的队列无法重新打开。
调用 close 完成后，以下条件成立：
-
closed?将返回 true -
close将被忽略。 -
调用 enq/push/<< 将引发一个
ClosedQueueError。 -
当
empty?为 false 时，调用 deq/pop/shift 将照常从队列返回一个对象。 -
当
empty?为 true 时，deq(false) 不会挂起线程并返回 nil。deq(true) 将引发ThreadError。
ClosedQueueError 继承自 StopIteration，因此您可以跳出循环块。
示例
q = Thread::Queue.new Thread.new{ while e = q.deq # wait for nil to break loop # ... end } q.close
Source
static VALUE
rb_queue_closed_p(VALUE self)
{
return RBOOL(queue_closed_p(self));
}
如果队列已关闭，则返回 true。
Source
static VALUE
rb_queue_empty_p(VALUE self)
{
return RBOOL(queue_length(self, queue_ptr(self)) == 0);
}
如果队列为空，则返回 true。
Source
static VALUE
rb_queue_freeze(VALUE self)
{
rb_raise(rb_eTypeError, "cannot freeze " "%+"PRIsVALUE, self);
UNREACHABLE_RETURN(self);
}
队列无法冻结，因此此方法会引发异常
Thread::Queue.new.freeze # Raises TypeError (cannot freeze #<Thread::Queue:0x...>)
Source
static VALUE
rb_queue_length(VALUE self)
{
return LONG2NUM(queue_length(self, queue_ptr(self)));
}
返回队列的长度。
也别名为：size
Source
static VALUE
rb_queue_num_waiting(VALUE self)
{
struct rb_queue *q = queue_ptr(self);
return INT2NUM(q->num_waiting);
}
返回正在等待队列的线程数。
Source
# File thread_sync.rb, line 16 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_queue_pop(non_block, timeout) end
从队列检索数据。
如果队列为空，则挂起调用线程，直到有数据被推入队列。如果 non_block 为 true，则线程不会挂起，并会引发 ThreadError。
如果在 timeout 秒后仍无可用数据，则返回 nil。如果 timeout 为 0，则立即返回。
Source
static VALUE
rb_queue_push(VALUE self, VALUE obj)
{
return queue_do_push(self, queue_ptr(self), obj);
}
将给定的 object 推入队列。