Java簡單方法實現(xiàn)子任務(wù)耗時統(tǒng)計

更新時間：2026年01月13日 09:08:19 作者：樺說編程

在并發(fā)編程中,我們經(jīng)常需要將一個大任務(wù)拆分成多個子任務(wù)并行執(zhí)行,但隨之而來的問題是如何準(zhǔn)確統(tǒng)計每個子任務(wù)的耗時,下面我們來看看如何使用Java實現(xiàn)吧

背景

在并發(fā)編程中，我們經(jīng)常需要將一個大任務(wù)拆分成多個子任務(wù)并行執(zhí)行。但隨之而來的問題是：如何準(zhǔn)確統(tǒng)計每個子任務(wù)的耗時？

傳統(tǒng)的做法是在業(yè)務(wù)代碼中手動埋點，但這樣會導(dǎo)致代碼侵入性強、難以維護。本文介紹一種基于裝飾器模式的優(yōu)雅實現(xiàn)方案。

核心思路

通過包裝 Callable 接口，在任務(wù)執(zhí)行前后自動記錄時間戳，實現(xiàn)對任務(wù)生命周期各階段的監(jiān)控：

Timeline: submitTime -> startTime -> endTime
| | |
+-- 等待時間 --+-- 執(zhí)行時間 --+
| |
+------- 總耗時 -----------+

代碼實現(xiàn)

1. 定義時間記錄字段

public class ScopedCallable<V> implements Callable<V> {

    private static final long NANO_TO_MS = 1_000_000L;

    /** 任務(wù)名稱 */
    private final String taskName;

    /** 被包裝的實際任務(wù) */
    private final Callable<V> delegate;

    /** 任務(wù)提交時間 (納秒) */
    private final long submitTime;

    /** 任務(wù)開始執(zhí)行時間 (納秒) */
    private long startTime;

    /** 任務(wù)執(zhí)行結(jié)束時間 (納秒) */
    private long endTime;
}

2. 在構(gòu)造函數(shù)中記錄提交時間

public ScopedCallable(String taskName, Callable<V> delegate) {
    this.taskName = Objects.requireNonNull(taskName);
    this.delegate = Objects.requireNonNull(delegate);
    this.submitTime = System.nanoTime();  // 記錄提交時間
}

3. 在 call() 方法中記錄執(zhí)行時間

@Override
public V call() throws Exception {
    try {
        startTime = System.nanoTime();   // 記錄開始時間
        return delegate.call();           // 執(zhí)行實際任務(wù)
    } finally {
        endTime = System.nanoTime();      // 記錄結(jié)束時間
        reportMetrics();                  // 上報監(jiān)控指標(biāo)
    }
}

4. 計算各階段耗時

/** 執(zhí)行耗時 = 結(jié)束時間 - 開始時間 */
public long executionTime() {
    return endTime - startTime;
}

/** 等待耗時 = 開始時間 - 提交時間 */
public long waitTime() {
    return startTime - submitTime;
}

/** 總耗時 = 結(jié)束時間 - 提交時間 */
public long totalTime() {
    return endTime - submitTime;
}

5. 上報監(jiān)控指標(biāo)

private void reportMetrics() {
    long execMs = executionTime() / NANO_TO_MS;
    long waitMs = waitTime() / NANO_TO_MS;
    long totalMs = totalTime() / NANO_TO_MS;

    System.out.println("[" + taskName + "] 執(zhí)行耗時: " + execMs + "ms");
    System.out.println("[" + taskName + "] 等待耗時: " + waitMs + "ms");
    System.out.println("[" + taskName + "] 總耗時: " + totalMs + "ms");
}

設(shè)計要點

要點	說明
納秒精度	使用 System.nanoTime() 而非 currentTimeMillis()，精度更高且不受系統(tǒng)時鐘調(diào)整影響
finally 塊	確保即使任務(wù)拋異常也能記錄結(jié)束時間
透明包裝	對業(yè)務(wù)代碼無侵入，只需在提交任務(wù)時包裝一層

使用示例

public static void main(String[] args) throws Exception {
    ExecutorService executor = Executors.newFixedThreadPool(2);

    // 提交包裝后的任務(wù)
    Future<String> future = executor.submit(
        new ScopedCallable<>("queryDB", () -> {
            Thread.sleep(100);  // 模擬耗時操作
            return "result";
        })
    );

    System.out.println("結(jié)果: " + future.get());
    executor.shutdown();
}

輸出示例：