java - 线程之间的可见性是否需要 AtomicReference？

Question

我正在使用一个在发送请求时需要回调的框架。每个回调都必须实现此接口(interface)。回调中的方法是异步调用的。

public interface ClientCallback<RESP extends Response>
{
  public void onSuccessResponse(RESP resp);

  public void onFailureResponse(FailureResponse failure);

  public void onError(Throwable e);
}

为了使用 TestNG 编写集成测试，我想要一个阻塞回调。所以我使用了 CountDownLatch 在线程之间进行同步。

这里真的需要 AtomicReference 还是原始引用好吗？我知道如果我使用原始引用和原始整数(而不是 CountDownLatch)，代码将无法工作，因为可见性不能保证。但是由于 CountDownLatch 已经同步，我不确定是否需要来自 AtomicReference 的额外同步。注意:Result 类是不可变的。

public class BlockingCallback<RESP extends Response> implements ClientCallback<RESP>
{
  private final AtomicReference<Result<RESP>> _result = new AtomicReference<Result<RESP>>();
  private final CountDownLatch _latch = new CountDownLatch(1);

  public void onSuccessResponse(RESP resp)
  {
    _result.set(new Result<RESP>(resp, null, null));
    _latch.countDown();
  }

  public void onFailureResponse(FailureResponse failure)
  {
    _result.set(new Result<RESP>(null, failure, null));
    _latch.countDown();
  }

  public void onError(Throwable e)
  {
    _result.set(new Result<RESP>(null, null, e));
    _latch.countDown();
  }

  public Result<RESP> getResult(final long timeout, final TimeUnit unit) throws InterruptedException, TimeoutException
  {
    if (!_latch.await(timeout, unit))
    {
      throw new TimeoutException();
    }
    return _result.get();
  }

Answer 1

您不需要在这里使用另一个同步对象 (AtomicRefetence)。关键是该变量在一个线程中调用 CountDownLatch 之前设置，并在另一个线程中调用 CountDownLatch 之后读取。 CountDownLatch 已经执行线程同步并调用内存屏障，因此保证了前写后读的顺序。因此，您甚至不需要为该字段使用 volatile。