public class LatchVsBarrier {
    
    public static void main(String[] args) throws InterruptedException {
        //CountDownLatch одноразовый
        CountDownLatch latch = new CountDownLatch(3);
        
        // Первая фаза: ожидаем 3 потока
        for (int i = 0; i < 3; i++) {
            new Thread(() -> {
                // работа
                latch.countDown();
            }).start();
        }
        latch.await(); // ждем завершения первой фазы
        System.out.println("Первая фаза завершена");
        
        // Попытка второй фазы — бессмысленна, latch уже на нуле
        // Новые потоки, вызывающие latch.await(), пройдут без ожидания
        // latch.countDown() не имеет эффекта
        
        //CyclicBarrier переиспользуется
        CyclicBarrier barrier = new CyclicBarrier(3, () -> 
            System.out.println("Барьер достигнут, выполняется действие"));
        
        Runnable task = () -> {
            try {
                // Первая итерация
                System.out.println(Thread.currentThread().getName() + " готов к фазе 1");
                barrier.await();
                // работа после барьера
                System.out.println(Thread.currentThread().getName() + " завершил фазу 1");
                
                // Вторая итерация — барьер сброшен автоматически
                System.out.println(Thread.currentThread().getName() + " готов к фазе 2");
                barrier.await();
                System.out.println(Thread.currentThread().getName() + " завершил фазу 2");
            } catch (InterruptedException | BrokenBarrierException e) {
                Thread.currentThread().interrupt();
            }
        };
        
        for (int i = 0; i < 3; i++) {
            new Thread(task).start();
        }
    }
}

import java.util.concurrent.CountDownLatch;

public class Task140726 {
    public static void main(String[] args) throws InterruptedException {
        CountDownLatch latch = new CountDownLatch(1);
        latch.countDown();
        
        for (int i = 0; i < 3; i++) {
            latch.await();
            System.out.print(i + " ");
        }
        System.out.print(latch.getCount());
    }
}

import java.nio.file.*;
import java.io.IOException;

public class FileMover {
    
    public void renameFile(Path oldName, Path newName) throws IOException {
        // Простое переименование в той же директории
        Files.move(oldName, newName);
    }
    
    public void moveToArchive(Path file, Path archiveDir) throws IOException {
        // Перемещение в другую директорию
        Path target = archiveDir.resolve(file.getFileName());
        Files.move(file, target);
    }
}

Path src = Paths.get("/data/report_v1.txt");
Path dst = Paths.get("/data/report.txt");

// Перезаписываем старый отчёт новым
Files.move(src, dst, StandardCopyOption.REPLACE_EXISTING);

Path src = Paths.get("/data/temp_report.txt");
Path dst = Paths.get("/data/report.txt");

// Атомарное переименование: читатели либо видят старый файл, либо новый
Files.move(src, dst, StandardCopyOption.ATOMIC_MOVE);

import java.nio.file.*;
import java.io.IOException;
import java.time.Instant;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;

public class ArchiveMover {
    
    private static final DateTimeFormatter DATE_FORMAT = 
        DateTimeFormatter.ofPattern("yyyy-MM-dd").withZone(ZoneId.systemDefault());
    
    public void archiveProcessedFile(Path processedFile, Path archiveRoot) throws IOException {
        // Проверяем, что источник существует и является файлом
        if (!Files.isRegularFile(processedFile)) {
            throw new NoSuchFileException("Файл не найден или не является обычным файлом: " + processedFile);
        }
        
        // Создаём архивную директорию с текущей датой: /archive/2024-07-14/
        String today = DATE_FORMAT.format(Instant.now());
        Path datedArchive = archiveRoot.resolve(today);
        Files.createDirectories(datedArchive);
        
        // Формируем целевой путь
        String fileName = processedFile.getFileName().toString();
        Path target = datedArchive.resolve(fileName);
        
        // Если файл с таким именем уже есть в архиве — добавляем счётчик
        Path finalTarget = resolveUniqueName(target);
        
        // Атомарное перемещение
        Files.move(processedFile, finalTarget, StandardCopyOption.ATOMIC_MOVE);
        
        System.out.println("Файл перемещён в архив: " + finalTarget.toAbsolutePath());
    }
    
    private Path resolveUniqueName(Path target) {
        if (Files.notExists(target)) {
            return target;
        }
        
        // Генерируем уникальное имя: file.txt -> file_1.txt, file_2.txt
        String fileName = target.getFileName().toString();
        int lastDot = fileName.lastIndexOf('.');
        String base = lastDot > 0 ? fileName.substring(0, lastDot) : fileName;
        String ext = lastDot > 0 ? fileName.substring(lastDot) : "";
        Path parent = target.getParent();
        
        int counter = 1;
        Path candidate;
        do {
            candidate = parent.resolve(base + "_" + counter + ext);
            counter++;
        } while (Files.exists(candidate));
        
        return candidate;
    }
    
    public static void main(String[] args) {
        try {
            Path file = Paths.get("/app/inbox/order_12345.xml");
            Path archive = Paths.get("/app/archive");
            new ArchiveMover().archiveProcessedFile(file, archive);
        } catch (AtomicMoveNotSupportedException e) {
            System.err.println("Атомарное перемещение невозможно — источник и архив на разных разделах");
            // Fallback: копирование + удаление
        } catch (IOException e) {
            System.err.println("Ошибка архивирования: " + e.getMessage());
        }
    }
}

Path file = Paths.get("/tmp/old_data.tmp");
Files.delete(file);  // NoSuchFileException, если файла нет

Path tempFile = Paths.get("/tmp/session_abc123.tmp");
boolean wasDeleted = Files.deleteIfExists(tempFile);
if (wasDeleted) {
    System.out.println("Временный файл удалён");
} else {
    System.out.println("Файл уже был удалён или не существовал");
}

Path dir = Paths.get("/tmp/myapp");
try {
    Files.delete(dir);  // DirectoryNotEmptyException, если внутри есть файлы
} catch (DirectoryNotEmptyException e) {
    // Нужно сначала удалить содержимое
}

import java.nio.file.*;
import java.io.IOException;
import java.util.Comparator;
import java.util.stream.Stream;

public class TreeDeleter {
    
    public void deleteDirectoryRecursively(Path root) throws IOException {
        if (!Files.exists(root)) {
            return;  // Нечего удалять
        }
        
        // walk возвращает Stream<Path> в порядке pre-order (родитель до детей)
        // sorted(reverseOrder()) переворачивает: сначала глубокие пути, потом корень
        try (Stream<Path> walk = Files.walk(root)) {
            walk.sorted(Comparator.reverseOrder())
                .forEach(path -> {
                    try {
                        Files.delete(path);
                    } catch (IOException e) {
                        // Оборачиваем в UncheckedIOException для использования в forEach
                        throw new UncheckedIOException(
                            "Не удалось удалить: " + path, e
                        );
                    }
                });
        } catch (UncheckedIOException e) {
            // Распаковываем обратно в checked исключение
            throw e.getCause();
        }
    }
}

import java.nio.file.*;
import java.io.IOException;
import java.util.stream.Stream;

public class TempCleaner {
    
    private static final Path TEMP_DIR = Paths.get(System.getProperty("java.io.tmpdir"));
    
    public void cleanTempFiles() throws IOException {
        // Проверяем, что TEMP_DIR существует и является директорией
        if (!Files.isDirectory(TEMP_DIR)) {
            throw new NotDirectoryException(TEMP_DIR.toString());
        }
        
        // Обходим только верхний уровень временной директории
        // newDirectoryStream — более лёгкая альтернатива walk для одного уровня
        try (DirectoryStream<Path> stream = Files.newDirectoryStream(TEMP_DIR)) {
            for (Path entry : stream) {
                if (Files.isRegularFile(entry) && entry.toString().endsWith(".tmp")) {
                    try {
                        Files.delete(entry);
                        System.out.println("Удалён: " + entry.getFileName());
                    } catch (IOException e) {
                        // Логируем, но продолжаем удаление остальных
                        System.err.println("Не удалось удалить " + entry.getFileName() 
                            + ": " + e.getMessage());
                    }
                }
            }
        }
    }
    
    // Альтернатива: удаление .tmp файлов рекурсивно во всём поддереве
    public void cleanTempFilesRecursive(Path root) throws IOException {
        try (Stream<Path> walk = Files.walk(root)) {
            walk.filter(Files::isRegularFile)
                .filter(p -> p.toString().endsWith(".tmp"))
                .forEach(p -> {
                    try {
                        Files.delete(p);
                        System.out.println("Удалён: " + p);
                    } catch (IOException e) {
                        System.err.println("Ошибка удаления " + p + ": " + e.getMessage());
                    }
                });
        }
    }
    
    // Удаление .tmp файлов старше N дней
    public void cleanOldTempFiles(int daysOld) throws IOException {
        long cutoff = System.currentTimeMillis() - (daysOld * 24 * 60 * 60 * 1000L);
        
        try (Stream<Path> walk = Files.walk(TEMP_DIR)) {
            walk.filter(Files::isRegularFile)
                .filter(p -> p.toString().endsWith(".tmp"))
                .filter(p -> {
                    try {
                        return Files.getLastModifiedTime(p).toMillis() < cutoff;
                    } catch (IOException e) {
                        return false;  // Не удалось прочитать — пропускаем
                    }
                })
                .forEach(p -> {
                    try {
                        Files.delete(p);
                        System.out.println("Удалён старый файл: " + p.getFileName());
                    } catch (IOException e) {
                        System.err.println("Ошибка: " + e.getMessage());
                    }
                });
        }
    }
    
    public static void main(String[] args) {
        try {
            TempCleaner cleaner = new TempCleaner();
            cleaner.cleanTempFiles();
            cleaner.cleanOldTempFiles(7);  // удалить .tmp старше 7 дней
        } catch (IOException e) {
            System.err.println("Ошибка очистки: " + e.getMessage());
        }
    }
}

public void deleteRecursivelySafe(Path root) throws IOException {
    // FileVisitor — интерфейс для обхода дерева с callback-методами
    Files.walkFileTree(root, new SimpleFileVisitor<Path>() {
        @Override
        public FileVisitResult visitFile(Path file, BasicFileAttributes attrs) 
                throws IOException {
            Files.delete(file);
            return FileVisitResult.CONTINUE;
        }
        
        @Override
        public FileVisitResult postVisitDirectory(Path dir, IOException exc) 
                throws IOException {
            if (exc != null) {
                throw exc;  // ошибка при обходе поддиректории
            }
            Files.delete(dir);
            return FileVisitResult.CONTINUE;
        }
    });
}

import java.nio.file.*;
import java.io.*;

public class Task150726 {
    public static void main(String[] args) throws IOException {
        Path source = Paths.get("file.txt");
        Path target = Paths.get("target.txt");

        Files.createFile(source);
        Files.createFile(target);

        try {
            Files.move(source, target);
            System.out.println("Moved");
        } catch (IOException e) {
            System.out.println(e.getClass().getSimpleName());
        }

        System.out.println(Files.exists(source));
    }
}

public class ThreadYield {
    private boolean flag = false;
    
    //Антипаттерн: yield() в цикле ожидания
    public void badWait() {
        while (!flag) {
            Thread.yield(); // Плохо: может никогда не сработать, а если сработает, то не факт
        }
        // Действие после флага
    }
    
    //Правильно: использование Lock или wait/notify
    private final Object lock = new Object();
    
    public void goodWait() throws InterruptedException {
        synchronized (lock) {
            while (!flag) {
                lock.wait(); // Блокируется до уведомления
            }
        }
    }
    
    public void setFlagTrue() {
        synchronized (lock) {
            flag = true;
            lock.notifyAll();
        }
    }
}

public class Task160726 {
    public static void main(String[] args) throws InterruptedException {
        Thread t1 = new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                System.out.print("A");
                Thread.yield();
            }
        });
        Thread t2 = new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                System.out.print("B");
                Thread.yield();
            }
        });
        t1.start();
        t2.start();
        t1.join();
        t2.join();
    }
}