lbarasti / agent Goto Github PK

$ cat fiber_safe_counter.cr  #
# compile with `crystal build -Dpreview_mt examples/fiber_safe_counter.cr`
# run with `CRYSTAL_WORKERS=8 ./fiber_safe_counter`
require "../src/agent"

done = Channel(Nil).new(10)
counter = Agent.new(0)

t0 = Time.utc

(1..100).each {
  spawn {
    (1..1024).each {
      counter.update { |x| x + 1 }
    }
    done.send nil
  }
}
10.times { done.receive }

t1 = Time.utc
puts t1-t0

puts counter.get # => 1024 * 10

$ crystal-1.3.2-1/bin/crystal build -Dpreview_mt fiber_safe_counter.cr 
$CRYSTAL_WORKERS=2 ./fiber_safe_counter
00:00:00.136953628
96824

$CRYSTAL_WORKERS=2 ./fiber_safe_counter
00:00:00.150021704
100215

$CRYSTAL_WORKERS=1 ./fiber_safe_counter
00:00:00.180829373
102400