Я не могу сказать что-либо окончательное, не видя остальную часть класса, и, возможно, некоторые другие классы, которые он использует, но похоже, что это может быть состояние гонки, то есть несколько потоков, которые непредсказуемым образом мешают друг другу , Особенно многократное использование Schedulers.quant
, по-видимому, несинхронизированной статической переменной, выглядит крайне подозрительно.
Если это действительно состояние гонки, вам нужно прочитать эту книгу , а затем вернуться и исправить свой код; проблемы многопоточности могут быть очень сложными, и вам действительно нужно понять теорию, прежде чем писать многопоточный код.