Sha256: 26399d92d7ab93925ea985ddfb7d58ef5a4f589cec4bacfc62d8a9c6470bfd0d
Contents?: true
Size: 1.47 KB
Versions: 7
Compression:
Stored size: 1.47 KB
Contents
require 'test_helper'
class Workhorse::PoolTest < WorkhorseTest
def test_idle
with_pool 5 do |p|
assert_equal 5, p.idle
4.times do |_i|
p.post do
sleep 0.2
end
end
sleep 0.1
assert_equal 1, p.idle
sleep 0.2
assert_equal 5, p.idle
end
end
def test_on_idle
on_idle_calls = Concurrent::AtomicFixnum.new
with_pool 2 do |p|
p.on_idle { on_idle_calls.increment }
assert_equal 0, on_idle_calls.value
p.post { sleep 0.2 }
p.post { sleep 0.4 }
sleep 0.1
assert_equal 0, on_idle_calls.value
sleep 0.2
assert_equal 1, on_idle_calls.value
sleep 0.1
assert_equal 2, on_idle_calls.value
end
end
def test_overflow
with_pool 5 do |p|
5.times { p.post { sleep 0.2 } }
exception = assert_raises do
p.post { sleep 1 }
end
assert_equal 'All threads are busy.', exception.message
end
end
def test_work
with_pool 5 do |p|
counter = Concurrent::AtomicFixnum.new(0)
5.times do
p.post do
counter.increment
end
end
sleep 0.01
assert_equal 5, counter.value
2.times do
p.post do
counter.increment
end
end
sleep 0.01
assert_equal 7, counter.value
end
end
private
def with_pool(size)
p = Workhorse::Pool.new(size)
begin
yield(p)
ensure
p.shutdown
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems