Sha256: cd06a53f35f8f7f05df0bc8af58341ac6ebf500ebf5bf42b0b4ac4c8bc07a364
Contents?: true
Size: 1.54 KB
Versions: 13
Compression:
Stored size: 1.54 KB
Contents
require_relative 'test_helper'
describe "Adrian::Dispatcher lifecycle" do
class Worker < Adrian::Worker
def work
$done_items << item.value
end
end
before do
$done_items = []
@q = Adrian::ArrayQueue.new([1,2,3])
end
describe "stop_when_done" do
describe "set to true" do
before do
@dispatcher = Adrian::Dispatcher.new(:stop_when_done => true)
end
it "should have all the work done and stop" do
t = Thread.new do
@dispatcher.start(@q, Worker)
end
sleep(0.5)
@q.pop.must_be_nil
$done_items.must_equal([1,2,3])
@dispatcher.running.must_equal false
end
end
describe "set to false" do
before do
@dispatcher = Adrian::Dispatcher.new(:stop_when_done => false)
end
it "should have all the work done and continue" do
t = Thread.new do
@dispatcher.start(@q, Worker)
end
sleep(0.5)
@q.pop.must_be_nil
$done_items.must_equal([1,2,3])
@dispatcher.running.must_equal true
t.kill
end
end
end
describe "#stop" do
before do
@dispatcher = Adrian::Dispatcher.new(:sleep => 0.1)
end
it "should stop a running dispatcher" do
t = Thread.new do
@dispatcher.start(@q, Worker)
end
sleep(0.5)
@dispatcher.running.must_equal true
t.status.wont_equal false
@dispatcher.stop
sleep(0.5)
@dispatcher.running.must_equal false
t.status.must_equal false
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems