Ist es möglich, eine Warteschlange von Hintergrundaufgaben mit rxjava zu implementieren?
Ich brauche die Möglichkeit, eine Aufgabe jederzeit hinzuzufügen und nur eine Aufgabe gleichzeitig auszuführen. Ich habe PublishSubject ausprobiert, aber wenn ich die Ausführung in den neuen Thread observeOn(Schedulers.newThread()) dränge, startet es mehr als eine Aufgabe.
UPDATE: Ist es möglich, mit rxjava so etwas wie Erzeuger-Verbraucher-Muster zu implementieren?
Verwenden Sie einfach einen Scheduler, der auf einem einzigen Thread-Executor basiert:
%Vor%