cannot interrupt reactor if a queue is active

[emiltin]

I found that interrupting a reactor doesn't work if a subtask is waiting for a queue.

require 'async'
require 'async/queue'

reactor = Async::Reactor.new
queue = Async::Queue.new

puts 'a'
reactor.run do |task|
  task.async do
    queue.dequeue
  end
  reactor.interrupt
end

puts 'b'
reactor.run do
  reactor.interrupt
  puts 'c'
end

puts 'd'        # this is never reached

The first interrupt works, but the second somehow doesn't.

On MacOS.

% bundle exec gem list async
*** LOCAL GEMS ***
async (2.6.2)
async-io (1.35.0)

% ruby -v
ruby 3.2.2 (2023-03-30 revision e51014f9c0) [arm64-darwin22]

[ioquatix]

Hmm, odd, I'll take a look.

[ioquatix]

This should be fixed, please feel free to test it and report back.

[emiltin]

works for me thanks!