import java.util.concurrent.ConcurrentHashMap;

public class task170826 {
    
    public static void main(String[] args) {
        
        ConcurrentHashMap<Integer, String> map = new ConcurrentHashMap<>();
        map.put(1, "one");
        map.put(2, "two");
        map.put(3, "three");
        
        for (Integer key : map.keySet()) {
            if (key == 2) {
                map.remove(1);
                map.remove(3);
            }
        }
        System.out.println(map.size());
    }
}

import java.net.InetAddress;

public class Task180826 {
    public static void main(String[] args) throws Exception {
        byte[] ip = {127, 0, 0, 1};
        InetAddress addr1 = InetAddress.getByAddress("host1", ip);
        InetAddress addr2 = InetAddress.getByAddress("host2", ip);

        System.out.println(addr1.equals(addr2));
        System.out.println(addr1.getHostName().equals(addr2.getHostName()));
    }
}

import java.net.HttpURLConnection;
import java.net.URL;

public class Task190826 {
    public static void main(String[] args) throws Exception {
        URL url = new URL("http://example.com");
        HttpURLConnection conn = (HttpURLConnection) url.openConnection();
        System.out.println(conn.getResponseCode());
    }
}

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());
    }
}