Skip to content

Commit f23ac1f

Browse files
committed
Improve the robustness of the reactor interrupt test.
1 parent 2f18444 commit f23ac1f

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

test/async/reactor.rb

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -128,15 +128,19 @@
128128
it "can stop reactor from different thread" do
129129
events = Thread::Queue.new
130130

131+
reactor = self.reactor
132+
131133
thread = Thread.new do
132134
if events.pop
133-
reactor.interrupt
135+
2.times do
136+
reactor.interrupt
137+
sleep(0.01)
138+
end
134139
end
135140
end
136141

137142
reactor.async do
138143
events << true
139-
140144
# Wait to be interrupted:
141145
sleep
142146
end

0 commit comments

Comments
 (0)