AsyncContextImpl$future字段没有并发控制

[Ech0Fan]

• Dubbo version: latest

https://github.com/apache/dubbo/blob/dubbo-2.7.8/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/AsyncContextImpl.java

private final AtomicBoolean started = new AtomicBoolean(false);
private CompletableFuture<Object> future;

public void start() {
    if (this.started.compareAndSet(false, true)) {
        this.future = new CompletableFuture<>();
    }
 }

public void write(Object value) {
    if (isAsyncStarted() && stop()) {
        if (value instanceof Throwable) {
            Throwable bizExe = (Throwable) value;
            future.completeExceptionally(bizExe);
        } else {
            future.complete(value);
        }
    } else {
        // ignored
    }
}

当isAsyncStarted()返回true时确定能保证future字段的可见性么？

[ljluestc]

为了确保 future 字段在被多个线程访问时的可见性和一致性，您可以将其声明为 volatile，或者使用适当的同步机制（如同步块或 Lock 对象）在 future 字段的写入和读取操作之间建立发生之前关系 。