We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
io_uring
1 parent b6c5fe5 commit 83e395eCopy full SHA for 83e395e
1 file changed
test/async/barrier.rb
@@ -18,29 +18,22 @@
18
19
with "#async" do
20
let(:repeats) {40}
21
- let(:delay) {0.01}
22
23
it "should wait for all jobs to complete" do
24
finished = 0
25
26
repeats.times.map do |i|
27
barrier.async do |task|
28
- sleep(delay)
+ task.yield
29
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
35
end
36
37
38
expect(barrier).not.to be(:empty?)
39
- expect(finished).to be < repeats
+ expect(finished).to be <= repeats
40
41
- duration = Async::Clock.measure{barrier.wait}
+ barrier.wait
42
43
- expect(duration).to be_within(repeats * Sus::Fixtures::Time::QUANTUM).of(delay)
44
expect(finished).to be == repeats
45
expect(barrier).to be(:empty?)
46
0 commit comments