java - 以单线程方式包装回调函数

Question

在我的程序中，我实际上是在尝试连接到发布者并获取数据。这些步骤中包含基本功能

1. 我使用用户名和密码等与发布者建立连接
2. 我请求数据。方法退出
3. 发布者的 API 为我提供了一个回调方法 onDataUpdate(Object theUpdate)

从那里，我可以打印数据，或将其写入数据库或任何我需要做的事情。一切正常。

我的问题是，我现在想以这样一种方式包装功能，即调用程序可以请求数据并在我拥有数据后立即接收它。意思是，我希望我公开的方法看起来像

public Object getData() {
    subscribeForData();
    // somehow wait
    return theUpdate;    
}

我怎样才能做到这一点？当我收到更新时，有什么方法可以使用线程来等待/通知？我是 stackoverflow 和多线程编程的新手，所以非常感谢任何帮助和示例代码!!提前致谢。

Answer 1

在这种情况下，我更愿意使用 CountDownLatch ，在那里我将初始化我的 lathch 计数 1 一旦我订阅发布者我将在 latch 上调用 await() 并且当我得到回调我将 倒计时 闩锁。