akarnokd / akarnokd/reactive4java

Fairness of range() and repeat()

Aberta
#2 0 comentários 0 reações 0 responsáveis Ver no GitHub
auto-migrated Priority-Medium Type-Enhancement
Linguagem predominante
Java
Estrelas
3
Forks
0
Métricas de merge de PRs
Nenhum PR com merge em 30d

Descrição

```
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

Guia de contribuição

Nenhum guia de contribuição indexado para este repositório

Avaliação

Esta issue ainda não foi avaliada.

Receba novas issues na sua caixa de entrada

Um resumo curto de issues do GitHub para quem está começando.