import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;

public class BlockingQueueMethods {
    
    private final BlockingQueue<String> queue = new ArrayBlockingQueue<>(1);
    
    //Опасный вариант: put() блокирует навсегда
    public void badPut() throws InterruptedException {
        queue.put("item"); // Если очередь полна, поток зависнет навсегда
        // Никогда не вернется, если никто не потребит
    }
    
    //Правильно: try с таймаутом
    public boolean safeOffer(String item) throws InterruptedException {
        if (queue.offer(item, 1, TimeUnit.SECONDS)) {
            System.out.println("Элемент добавлен");
            return true;
        } else {
            System.out.println("Очередь заполнена, таймаут");
            return false;
        }
    }
    
    //Опасный вариант: poll() без таймаута возвращает null немедленно
    public String badPoll() {
        return queue.poll(); // null, если очередь пуста — нужно проверять!
    }
    
    //Блокирующее извлечение, когда нужно ждать
    public String takeItem() throws InterruptedException {
        return queue.take(); // ждет, пока появится элемент
    }
    
    //Извлечение с таймаутом
    public String pollWithTimeout() throws InterruptedException {
        String item = queue.poll(500, TimeUnit.MILLISECONDS);
        if (item != null) {
            System.out.println("Получен: " + item);
        } else {
            System.out.println("Таймаут, элемент не появился");
        }
        return item;
    }
}

import java.util.concurrent.*;

public class Task200826 {
    public static void main(String[] args) throws InterruptedException {
        BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(1);
        queue.put(1);

        Thread consumer = new Thread(() -> {
            try {
                Thread.sleep(2000);
                queue.take();
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        });
        consumer.start();

        boolean added = queue.offer(2, 1, TimeUnit.SECONDS);
        System.out.println(added);
        System.out.println(queue.size());
    }
}

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;

public class Task210826 {
    public static void main(String[] args) throws Exception {
        HttpClient client = HttpClient.newHttpClient();
        HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create("https://httpbin.org/post"))
                .POST(HttpRequest.BodyPublishers.ofString("data"))
                .GET()
                .build();
        HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
        System.out.println(response.statusCode());
    }
}