Set of standard producers and updated queue implementations with some

[akarnokd]

platform-safe variants.

[davidmoten]

I think we could spruce up this class with the naming. This class doesn't emit anything, the emit loop actually performs requests so is a request loop (which may induce emissions elsewhere perhaps but I don't think that justifies the use of emit).

Perhaps emitting -> busy or requesting and emitLoop->requestLoop

[akarnokd]

It's named after the emitter-loop pattern and I'd like to keep it named this way so developers can recognize it.

[davidmoten]

Yeah I noticed the naming pattern from your blogs and I think instead of a queue drainer and an emitter they are better described as both queue drainers except one is aysnc biased and the other is sync biased.

[benjchristensen]

If we are copying this from somewhere I think we should include the URL to where it came from and associated copyright information.

[benjchristensen]

This looks like good additions. If I understand correctly there are two things happening here:

1. Abstract Producers to simplify building Observables/Operators
2. New impls of queues that use Atomics rather than Unsafe so they work on Android, Google App Engine, etc?

The only thing I would like changed before merging is to include correct attribution to where the code comes from.

[akarnokd]

Sure, I'll add the link. These aren't all the android-compatible variants so I plan to do a separate PR on the remaining and updating all platform-checked places.

[benjchristensen]

I plan to do a separate PR on the remaining and updating all platform-checked places.

Then should the producers and queues be separated into different PRs?

[akarnokd]

The default constructor of QueuedProducer uses SpscLinkedQueue so at least they need to be in the same PR, but MpscLinkedQueue can be added after if you wish.

[benjchristensen]

Since these don't change any existing code and are all internal, let's merge and move forward.

[akarnokd]

Okay.