Re: java.util.concurrent.Flow with opposite direction of item flow
Alex Otenko via Concurrency-interest <[email protected]>
| Newsgroups | gmane.comp.java.jsr.166-concurrency |
|---|---|
| Message-ID | <CANkgWKgKV_e3r=OdOMVcRfJZjNe8yPWoigvRCDs1xie4-esBoQ@mail.gmail.com> |
Backpressure awareness is when the component can tell when it is going to get blocked. Blocking is the result of being unaware - the queue doesn't provide any API that the Producer can interact with to work out when it is going to get blocked. RxJava and JDK Flow provide such an API. Alex On Thu, 19 Dec 2019, 17:07 Alexei Kaigorodov via Concurrency-interest, < [email protected]> wrote: > "But the Blocking Queue in the middle implies that you want a Producer that > is not backpressure-aware" > No. In synchronous (pure multithreaded) case, Producer is > backpressure-aware: it is blocked when the queue is full. > And I want to keep backpressure in async case, both for Producer writing to > the queue, and for Consumer reading from the queue. > > > > -- > Sent from: http://jsr166-concurrency.10961.n7.nabble.com/ > _______________________________________________ > Concurrency-interest mailing list > [email protected] > http://cs.oswego.edu/mailman/listinfo/concurrency-interest > _______________________________________________ Concurrency-interest mailing list [email protected] http://cs.oswego.edu/mailman/listinfo/concurrency-interest