benchmark/vm_thread_sized_queue3.yml


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

benchmark:
  vm_thread_sized_queue3: |
    require 'thread'
    # many producers, one consumer
    n = 1_000_000
    m = 10
    q = Thread::SizedQueue.new(100)
    consumer = Thread.new do
      while q.pop
        # consuming
      end
    end

    producers = m.times.map do
      Thread.new do
        while n > 0
          q.push true
          n -= 1
        end
      end
    end
    producers.each(&:join)
    q.push nil
    consumer.join
loop_count: 1