我有一个容量为1的BlockingQueue。它存储收到的股票的最新价格。价格将一直保留在队列中,直到客户端轮询队列为止。然后,我有一个名为getLatestPrice()
的方法,该方法应返回该股票的最新价格。我的问题是,如果客户端尚未轮询最新价格,则最新价格可能不在队列中。它可能在阻塞的线程中。如果遭到封锁,退回最新价格的最佳解决方案是什么?谢谢。
private final BlockingQueue<PriceUpdate> latest;
private final long pollTimeout = 2;
private TimeUnit pollTimeUnit = TimeUnit.SECONDS;
public SaveListener(int capacity) {
latest = new ArrayBlockingQueue<PriceUpdate>(capacity, true);
}
public void newPrice(PriceUpdate priceUpdate) {
try {
latest.put(priceUpdate);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public PriceUpdate getNewPrice() {
try {
return latest.poll(pollTimeout, pollTimeUnit); }
catch (InterruptedException e) {
return null;
}
}
getLatestPrice()
调用getNewPrice
,尽管我知道队列中存储了一个值,但它没有返回任何值。 最佳答案
使AtomicReference保持最新值,它不会在更新时被阻止。