File: with_queue.rb

package info (click to toggle)
ruby-parallel 1.22.1-3
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid, trixie
  • size: 464 kB
  • sloc: ruby: 1,930; makefile: 4
file content (25 lines) | stat: -rw-r--r-- 443 bytes parent folder | download | duplicates (2) 
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
 
# frozen_string_literal: true
require './spec/cases/helper'

type = :"in_#{ARGV.fetch(0)}"

class Callback
  def self.call(x)
    "ITEM-#{x}"
  end
end

queue = Queue.new
Thread.new do
  sleep 0.2
  queue.push 1
  queue.push 2
  queue.push 3
  queue.push Parallel::Stop
end

if type == :in_ractors
  puts(Parallel.map(queue, type => 2, ractor: [Callback, :call]))
else
  puts(Parallel.map(queue, type => 2) { |(i, _id)| Callback.call i })
end