Java | Фишки и трюки

public class Quest {
    public static final Quest INSTANCE = new Quest();
    private final int yearsAgo;
    private static final int CURRENT_YEAR = Calendar.getInstance().get(Calendar.YEAR);

    private Quest() {
        yearsAgo = CURRENT_YEAR - 2000;
    }

    public int yearsAgo() {
        return yearsAgo;
    }

    public static void main(String[] args) {
        System.out.println(INSTANCE.yearsAgo());
    }
}

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public class ProjectReactorExample {
    public static void main(String[] args) {
        // Пример с Mono
        Mono<String> monoExample = Mono.just("Hello, Reactor!");
        monoExample
            .map(String::toUpperCase) // Преобразуем строку в верхний регистр
            .subscribe(System.out::println); // Подписываемся и выводим результат

        // Пример с Flux
        Flux<Integer> fluxExample = Flux.just(1, 2, 3, 4, 5);
        fluxExample
            .filter(num -> num % 2 == 0) // Фильтруем четные числа
            .map(num -> num * num) // Возводим в квадрат
            .subscribe(System.out::println); // Подписываемся и выводим результат
    }
}

var list = Arrays.asList(1, 2, 3, 3, 4, 5, 5);
var distinctList = list.stream()
                       .distinct()
                       .collect(Collectors.toList());
// distinctList: [1, 2, 3, 4, 5]

import io.vavr.control.Try;

public class VavrExample {
    public static void main(String[] args) {
        // Попробуем выполнить деление
        Try<Double> result = Try.of(() -> divide(10, 0)); // Делим на ноль

        // Обработка результата
        result.onSuccess(value -> System.out.println("Результат: " + value)) // Если успешно
              .onFailure(ex -> System.out.println("Ошибка: " + ex.getMessage())); // Если произошла ошибка
    }

    // Метод деления
    private static double divide(int a, int b) {
        return a / b; // Здесь может произойти исключение
    }
}

public class LoomExample {
    public static void main(String[] args) {
        // Создаем виртуальный поток
        Thread.startVirtualThread(() -> {
            System.out.println("Hello from a virtual thread!");
        });

        // Основной поток продолжает работу
        System.out.println("Hello from the main thread!");
    }
}

public class Quest {
    public static void main(String[] args) {
        System.out.println(4_32l + 4_32l);
    }
}

import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;

@Retention(RetentionPolicy.RUNTIME)
@interface Inject {}

class Service {
    public void serve() {
        System.out.println("Service is working!");
    }
}

class Client {
    @Inject
    private Service service;

    public void doSomething() {
        service.serve();
    }
}

import java.lang.reflect.Field;

class DIContainer {
    public static void inject(Object obj) {
        Class<?> clazz = obj.getClass();
        
        for (Field field : clazz.getDeclaredFields()) {
            if (field.isAnnotationPresent(Inject.class)) {
                try {
                    field.setAccessible(true); // Делаем поле доступным
                    Object dependency = field.getType().getDeclaredConstructor().newInstance(); // Создаем экземпляр зависимости
                    field.set(obj, dependency); // Внедряем зависимость
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

public class Main {
    public static void main(String[] args) {
        Client client = new Client();
        DIContainer.inject(client); // Внедряем зависимости

        client.doSomething(); // Вывод: Service is working!
    }
}

public class Quest {
    public static void main(String[] args) {
        System.out.print(op1() + op2() * op3());
    }

    private static int op1() {
        System.out.print(1);
        return 1;
    }
    private static int op2() {
        System.out.print(2);
        return 2;
    }
    private static int op3() {
        System.out.print(3);
        return 3;
    }
}

ExecutorService executor = Executors.newFixedThreadPool(5);

for (int i = 0; i < 10; i++) {
    final int taskId = i;
    executor.submit(() -> {
        System.out.println("Задача " + taskId + " выполняется в: " + Thread.currentThread().getName());
        // Имитация длительной задачи
        try {
            Thread.sleep(1000); // Задержка на 1 секунду
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
        System.out.println("Задача " + taskId + " завершена в: " + Thread.currentThread().getName());
    });
}

executor.shutdown(); // Ждем завершения всех задач