【发布时间】：2016-03-04 21:57:22
【问题描述】：
我正在使用一个在发送请求时需要回调的框架。每个回调都必须实现这个接口。回调中的方法是异步调用的。
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();
}
【问题讨论】：
-
不，不需要。任何形式的安全发布都可以使用（但原始参考不是 OK）。 C.f.这个堆栈溢出问题：stackoverflow.com/questions/801993/…
-
@markspace 你会推荐一个 volatile 变量吗？
-
实际上，这可能很棘手。
countDow()保证在对await()的任何调用之前发生。这里可以使用原始引用，因为每次写入_result之后都会调用countDown，而读取_result之前会调用await。所以_result实际上可以使用_latchs 可见性语义。 Brian Goetz 称此为捎带支持。 stackoverflow.com/questions/18732088/… -
实际上，如果这是现有的工作代码，我建议不要更改它。你不会有任何收获。如果您假设性地询问，那么 volatile 将起作用。捎带也有效，但很难发现。维护程序员很容易错过它。我建议对代码进行正式审查。如果没有人理解捎带，那么将其保留为 AtomicReference。
-
@Markspace 你在那里很困惑。同步锁存器的要点之一是提供可见性保证。如果您开始不依赖这些，则必须在任何地方使用 AtomicReferences 或 volatile。显然，原始参考是正确的选择，留下其他内容只会让未来的读者感到困惑。
标签： java multithreading