multithreading - 它有 crystal-lang 队列吗？

Question

如何在Crystal lang上实现生产者-消费者模式？我正在寻找类似的东西 - http://ruby-doc.org/core-2.2.0/Queue.html 可能我需要使用Channel，但我不明白如何使用..因为它需要等待“消费者”接收。

我的意思是:

channel = Channel(Int32).new

spawn do
  15.times do |i|
    # ... do something that take a time
    puts "send #{i}"
    channel.send i # paused while someone receive, but i want to continue do the job that takes a time..
  end
end

spawn do
  loop do
    i = channel.receive
    puts "receive #{i}"
    sleep 0.5
  end
end

sleep 7.5

Answer 1

你是对的，使用 Channel是解决 Crystal 中并发通信的好方法。 请注意，默认情况下，Channel 只能存储一个值，直到收到该值为止。

但是您可以使用缓冲 Channel 来向 Channel 发送多个值，并且不需要立即接收它们。这本质上是一个 FIFO 队列，其中新项目在一端添加，并从另一端删除。

# Create a channel with a buffer for 32 values
channel = Channel(Int32).new(32)