Skip to content

Commit 99c7633

Browse files
committed
Barrier tests.
1 parent b6c5fe5 commit 99c7633

1 file changed

Lines changed: 3 additions & 10 deletions

File tree

test/async/barrier.rb

Lines changed: 3 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -18,29 +18,22 @@
1818

1919
with "#async" do
2020
let(:repeats) {40}
21-
let(:delay) {0.01}
2221

2322
it "should wait for all jobs to complete" do
2423
finished = 0
2524

2625
repeats.times.map do |i|
2726
barrier.async do |task|
28-
sleep(delay)
27+
task.yield
2928
finished += 1
30-
31-
# This task is a child task but not part of the barrier.
32-
task.async do
33-
sleep(delay*3)
34-
end
3529
end
3630
end
3731

3832
expect(barrier).not.to be(:empty?)
39-
expect(finished).to be < repeats
33+
expect(finished).to be <= repeats
4034

41-
duration = Async::Clock.measure{barrier.wait}
35+
barrier.wait
4236

43-
expect(duration).to be_within(repeats * Sus::Fixtures::Time::QUANTUM).of(delay)
4437
expect(finished).to be == repeats
4538
expect(barrier).to be(:empty?)
4639
end

0 commit comments

Comments
 (0)