akarnokd / akarnokd/reactive4java

Fairness of range() and repeat()

Offen
#2 0 Kommentare 0 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen
auto-migrated Priority-Medium Type-Enhancement
Vorherrschende Sprache
Java
Sterne
3
Forks
0
PR-Merge-Kennzahlen
Keine gemergten PRs in 30 T.

Beschreibung

```
The current implementation of repeatedly emitting values in the operators
range() and repeat() are unfair: they are monopolizing the underlying
scheduler. This is acceptable (and preferred from performance perspective) on
schedulers such as the default and new-thread. The current thread and EDT
schedulers however would suffer in such cases.

The resolution of course is to grain the value emission by re-scheduling the
body. The question is, how to present these alternatives to the user?

- separate names (rangeFair(), repeatFair())
- require a SchedulerLongRunning indicator interface to indicate that it is
able to run such operations above without problems?
- enhance the scheduler interface to present some capabilities and the normal
implementations just switch based on it.

```

Original issue reported on code.google.com by `akarn...@gmail.com` on 3 Apr 2012 at 3:20

Beitragsleitfaden

Für dieses Repository ist kein Beitragsleitfaden indexiert

Bewertung

Dieses Issue wurde noch nicht bewertet.

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.