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

我正在使用一个在发送请求时需要回调的框架。每个回调都必须实现此接口(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();
  }

最佳答案

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

关于java - 线程之间的可见性是否需要AtomicReference？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/34012595/