public static void main(String[] args) throws Exception {
Sinks.Many<Integer> sinks = Sinks.many()
.multicast()
.onBackpressureBuffer(); // Изучайте документацию. Тут много вариантов
sinks.asFlux()
.subscribe(System.out::println);
// В очереди ничего нет. Ничего не происходит
Thread.sleep(1000);
// Наполняем очередь элементами
sinks.tryEmitNext(1);
sinks.tryEmitNext(2);
sinks.tryEmitNext(3);
}
Как разогнать видеокарту на ноутбуке?
[mysql@18e90ee13a1a /]$ ps ax
PID TTY STAT TIME COMMAND
1 ? Ssl 0:14 mysqld
61 pts/0 Ss 0:00 /bin/sh -c [ -e /bin/bash ] && (/bin/bash || exit 0) || /bin/sh
67 pts/0 S 0:00 /bin/sh -c [ -e /bin/bash ] && (/bin/bash || exit 0) || /bin/sh
68 pts/0 S 0:00 /bin/bash
81 pts/0 R+ 0:00 ps ax