Jox provides buffered channels with a bounded capacity by default, if you want a more high-level API to implement this kind of things using virtual threads. ht

Jox provides buffered channels with a bounded capacity by default, if you want a more high-level API to implement this kind of things using virtual threads. https://github.com/softwaremill/jox https://github.com/softwaremill/jox