Ractor#receive supports filtering

[ko1]

https://bugs.ruby-lang.org/issues/17378

[marcandre]

In ractor_receive_block where there is b->type = basket_type_ref, don't we need to wake any sleeping thread/fiber (in the current Ractor) doing a Ractor.receive?

The following deadlocks:

assert_equal ':ok', %q{
  r = Ractor.new do
    t = Thread.new { Ractor.receive { sleep(0.2); _1 == :foo }  }
    sleep(0.1) # let thread receive first
    Ractor.receive { sleep(0.2); _1 == :bar }
    t.join
    :ok
  end
  r << :bar << :foo
  r.take
}

[ko1]

Unfortunately, all synchronization methods (receive, yield, take) doesn't support Threads because they share the synchronization data structures. It in my TODO list.

[marcandre]

Ah, ok, good to know.