Главная / Concurrency / Thread.sleep с Duration
Concurrency Начинающий

Thread.sleep с Duration

Использование Duration для самодокументирующихся временных значений.

Сравнение кода
✕ Java 8 
// What unit is 5000? ms? us?
Thread.sleep(5000);

// 2.5 seconds: math required
Thread.sleep(2500);
✓ Java 19+ 
Thread.sleep(
    Duration.ofSeconds(5)
);
Thread.sleep(
    Duration.ofMillis(2500)
);
Заметили проблему в этом коде? Сообщите нам.
Почему современный подход лучше
📖

Самодокументирующийся

Duration.ofSeconds(5) не вызывает двусмысленности.

🛡️

Безопасность единиц

Нет случайной передачи микросекунд вместо миллисекунд.

🧩

Компонуемый

Арифметика Duration: plus(), multipliedBy() и т.д.

Старый подход
Миллисекунды
Современный подход
Duration
Начиная с JDK
19
Сложность
Начинающий
Поддержка JDK
Thread.sleep с Duration
Доступно

Широко доступно с JDK 19 (сент. 2022)

Как это работает

Thread.sleep(Duration) делает единицу времени явной. Больше не нужно гадать, означает ли 5000 миллисекунды или микросекунды. Работает с Duration.ofSeconds, ofMillis, ofMinutes и т.д.

Связанная документация
Thread.sleep(Duration) ↗
Доказательство
Посмотреть исходник доказательства ↗
Похожие шаблоны
Concurrency Продвинутый

Stable values

Java 8
private volatile Logger logger;
Logger getLogger() {
    if (logger == null) {
        synchronized (this) {
            if (logger == null)
                logger = createLogger();
        }
    }
    return logger;
}
Java 25 (Preview)
private final StableValue<Logger> logger =
    StableValue.of(this::createLogger);

Logger getLogger() {
    return logger.get();
}
Наведите, чтобы увидеть современный ➜
JDK 25+ →
Concurrency Средний

Concurrent HTTP with virtual threads

Java 8
ExecutorService pool =
    Executors.newFixedThreadPool(10);
List<Future<String>> futures =
    urls.stream()
    .map(u -> pool.submit(
        () -> fetchUrl(u)))
    .toList();
// manual shutdown, blocking get()
Java 21+
try (var exec = Executors
    .newVirtualThreadPerTaskExecutor()) {
    var results = urls.stream()
        .map(u -> exec.submit(
            () -> client.send(req(u),
                ofString()).body()))
        .toList().stream()
        .map(Future::join).toList();
}
Наведите, чтобы увидеть современный ➜
JDK 21+ →
Concurrency Средний

CompletableFuture chaining

Pre-Java 8
Future<String> future =
    executor.submit(this::fetchData);
String data = future.get(); // blocks
String result = transform(data);
Java 8+
CompletableFuture.supplyAsync(
    this::fetchData
)
.thenApply(this::transform)
.thenAccept(IO::println);
Наведите, чтобы увидеть современный ➜
JDK 8+ →