首页 / Concurrency / 使用 Duration 的 Thread.sleep
Concurrency 入门

使用 Duration 的 Thread.sleep

使用 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 与其他 java.time API 无缝配合。

旧方式
毫秒
现代方式
Duration
自 JDK
19
难度
入门
JDK 支持
使用 Duration 的 Thread.sleep
可用

自 JDK 19 起广泛可用（2022 年 9 月）

工作原理

Thread.sleep(Duration) 使时间单位明确。不再需要猜测数字是毫秒、秒还是纳秒——Duration.ofSeconds(5) 一目了然。

相关文档
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+ →
分享 𝕏 🦋 in ⬡