import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Mono;

@RestController
public class HelloController {
    @GetMapping("/hello")
    public Mono<String> hello() {
        return Mono.just("Привет из WebFlux!"); // Асинхронный ответ
    }
}

Здесь метод возвращает Mono — сервер не блокируется, ответ "течёт" асинхронно. Для Flux: стриминг данных, как SSE (сервер-сент события).

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.reactive.function.server.RouterFunctions;
import org.springframework.web.reactive.function.server.ServerResponse;

@Configuration
public class RouterConfig {
    @Bean
    public RouterFunction<ServerResponse> routes() {
        return RouterFunctions.route()
            .GET("/hello", request -> ServerResponse.ok().bodyValue("Привет из роутера!"))
            .build();
    }
}

Это декларативно: опишите маршруты, обработчики возвращают ServerResponse с Mono/Flux.

public class Task161025 {
    public static void main(String[] args) {
        String s1 = "hello";
        String s2 = new String("hello").intern();
        String s3 = "he" + "llo";
        String s4 = new String("hello");
        
        System.out.println(s1 == s2);
        System.out.println(s1 == s3);
        System.out.println(s1 == s4);
        System.out.println(s2 == s4);
    }
}

javaimport java.util.LinkedList;
import java.util.Queue;

public class Main {
    public static void main(String[] args) {
        Queue<String> queue = new LinkedList<>();
        // Добавление
        queue.offer("Задача 1");
        queue.offer("Задача 2");
        System.out.println(queue);  // [Задача 1, Задача 2]

        // Просмотр
        System.out.println(queue.peek());  // Задача 1 (без удаления)
        System.out.println(queue);  // [Задача 1, Задача 2]

        // Извлечение
        String task = queue.poll();  // Задача 1
        System.out.println(task);    // Задача 1
        System.out.println(queue);   // [Задача 2]

        // Пустая очередь
        queue.poll();  // Задача 2
        System.out.println(queue.poll());  // null (без исключения)
    }
}

Вывод: Показывает FIFO — элементы извлекаются в порядке добавления, null при пустой очереди.

javaimport java.util.PriorityQueue;
import java.util.Queue;

public class Main {
    public static void main(String[] args) {
        Queue<Integer> queue = new PriorityQueue<>();
        queue.offer(3);
        queue.offer(1);
        queue.offer(2);
        System.out.println(queue);  // [1, 3, 2] — минимальный в начале

        System.out.println(queue.peek());  // 1
        System.out.println(queue.poll());  // 1
        System.out.println(queue);        // [2, 3]
    }
}

Нюанс: PriorityQueue сортирует по натуральному порядку (или Comparator), не FIFO.

import java.util.*;

public class Task171025 {
    public static void main(String[] args) {
        Queue<Integer> queue = new LinkedList<>();
        queue.offer(1);
        queue.offer(2);
        queue.offer(3);
        
        System.out.print(queue.peek() + " ");
        System.out.print(queue.poll() + " ");
        queue.offer(4);
        System.out.print(queue.remove() + " ");
        System.out.print(queue.element() + " ");
    }
}