java - 从 ThreadPoolExecutor 重写的函数以进行日志记录

Question

// code exactly taken from java concurrency in practice

public class TimingThreadPool extends ThreadPoolExecutor {
  private final ThreadLocal<Long> startTime
    = new ThreadLocal<Long>();
  private final Logger log = Logger.getLogger("TimingThreadPool");
  private final AtomicLong numTasks = new AtomicLong();
  private final AtomicLong totalTime = new AtomicLong();

  protected void beforeExecute(Thread t, Runnable r) {
    super.beforeExecute(t, r);
    log.fine(String.format("Thread %s: start %s", t, r));
    startTime.set(System.nanoTime());
  }

  protected void afterExecute(Runnable r, Throwable t) {
    try {
    long endTime = System.nanoTime();
    long taskTime = endTime - startTime.get();
    numTasks.incrementAndGet();
    totalTime.addAndGet(taskTime);
    log.fine(String.format("Thread %s: end %s, time=%dns",
            t, r, taskTime));
    } finally {
    super.afterExecute(r, t);
    }
}

protected void terminated() {
try {
    log.info(String.format("Terminated: avg time=%dns",
            totalTime.get() / numTasks.get()));
    } finally {
    super.terminated();
    }
}
}

实例是否ThreadPoolExecutor由所有工作线程共享。如果是，那么该方法beforeExecute(...)不afterExecute(...)应该同步？如果答案是否定的，那么原因是“局部变量是在线程堆栈中分配的，而 numTasks、totalTime、startTime 等状态变量是线程受限/原子的”。

Answer 1

您不需要同步 beforeExecute 和 afterExecute 因为这两个方法中使用的所有字段都是线程安全的 java.util.logging.Logger （来自 API - Logger 上的所有方法都是多线程安全的。）或 ThreadLocal 和 AtocmicLong 专门设计用于无锁使用。

至于局部变量，它们只能被一个线程访问，不需要任何同步。