будет ? )
новый элемент всегда только один, целиком очередь никогда не обновляется. приорити квае фиксед сайза. элемент из квае не удаляется до тех пор пока размер очереди меньше чем кол-во стримов, как только равно - отсекаем и вставляем новый элемент. и не забываем учитывать кто откуда, чтобы в квае не было одновременно больше 1 элемента с одного стрима. обычная же сортировка слиянием, которая всегда выполняется в пул режиме. только с нюансом что данные могут запаздывать и нет гарантии что все все головы доступны. поэтому барьер с очередью (или более хитрыми вариантами) (ну и в случае пуш стримов - еще бек преша по каждому стриму)
Обсуждают сегодня