java - Java中如何保证同一时间只有一个请求

Question

关闭。这个问题是 opinion-based 。目前不接受答案。

---

想要改进这个问题吗？更新问题，以便 editing this post 可以用事实和引文来回答它。 .

已关闭 5 年前。

Improve this question

我想实现如下调用:

public Response getContent() throws MyException

此方法在内部调用 Web 服务，但我只想同时向 Web 服务发出一个请求。也就是说:当第一个请求到来时，它会转到 Web 服务。如果同时有另一个请求到达，它将等待第一个请求的结果。第一个请求返回(或抛出异常)后，所有待处理的请求也返回(或抛出异常)。从这一点开始，如果另一个请求到来，它会再次以相同的条件转到 Web 服务(同时仅调用一个 Web 服务)

在 Java/Android 中实现此功能的最佳方法是什么？

谢谢

Answer 1

这是一个带有 CompletableFuture 的解决方案，它始终阻止等待新结果。如果您调用 get() 并且已有结果，则会触发新的提取并阻塞。如果提取已经在进行中，它将加入等待该结果的其他线程。

import java.util.concurrent.CompletableFuture
import java.util.concurrent.atomic.AtomicReference

class OneAtATime<out T> {
    private val pending = AtomicReference(CompletableFuture<T>())
    init {
        startFetching(pending.get())
    }

    fun get(): T {
        val current = pending.get()
        if (!current.isDone) {
            return current.get()
        }
        val next = CompletableFuture<T>()
        return if (pending.compareAndSet(current, next)) {
            startFetching(next)
            next.get()
        } else {
            pending.get().get()
        }
    }

    private fun startFetching(future: CompletableFuture<T>) {
        TODO("Implementation must call future.complete(newContent)")
    }
}