對(duì)于我的一個(gè)必須支持并發(fā)讀取和寫入的項(xiàng)目，我需要一個(gè)能夠緩沖項(xiàng)的容器，直到使用者一次獲取每個(gè)當(dāng)前緩沖的項(xiàng)。由于生產(chǎn)者應(yīng)該能夠生成數(shù)據(jù)，而不管消費(fèi)者是否讀取當(dāng)前緩沖區(qū)，我提出了一個(gè)自定義實(shí)現(xiàn)，在的幫助下，將每個(gè)條目添加到支持中，直到執(zhí)行翻轉(zhuǎn)，這會(huì)導(dǎo)致當(dāng)前條目被返回，同時(shí)存儲(chǔ)具有空隊(duì)列和元數(shù)據(jù)的新條目以原子方式存儲(chǔ)在該中。AtomicReferenceConcurrentLinkedQueueAtomicReference我想出了一個(gè)解決方案，例如public class FlippingDataContainer<E> {  private final AtomicReference<FlippingDataContainerEntry<E>> dataObj = new AtomicReference<>();  public FlippingDataContainer() {    dataObj.set(new FlippingDataContainerEntry<>(new ConcurrentLinkedQueue<>(), 0, 0, 0));  }  public FlippingDataContainerEntry<E> put(E value) {    if (null != value) {      while (true) {        FlippingDataContainerEntry<E> data = dataObj.get();        FlippingDataContainerEntry<E> updated = FlippingDataContainerEntry.from(data, value);        if (dataObj.compareAndSet(data, updated)) {          return merged;        }      }    }    return null;  }  public FlippingDataContainerEntry<E> flip() {    FlippingDataContainerEntry<E> oldData;    FlippingDataContainerEntry<E> newData = new FlippingDataContainerEntry<>(new ConcurrentLinkedQueue<>(), 0, 0, 0);    while (true) {      oldData = dataObj.get();      if (dataObj.compareAndSet(oldData, newData)) {        return oldData;      }    }  }  public boolean isEmptry() {    return dataObj.get().getQueue().isEmpty();  }}由于其他線程在此線程可以執(zhí)行更新之前更新值可能會(huì)導(dǎo)致可能的重試，因此我需要在每次寫入嘗試時(shí)復(fù)制實(shí)際隊(duì)列，否則即使原子引用無法更新，也會(huì)將條目添加到共享隊(duì)列中。因此，只需將值添加到共享隊(duì)列中，就可能導(dǎo)致值條目多次添加到隊(duì)列中，而實(shí)際上它只應(yīng)出現(xiàn)一次。雖然與復(fù)制隊(duì)列的代碼相比，這允許運(yùn)行測(cè)試的速度快10倍以上，但它也經(jīng)常無法通過消耗測(cè)試，因?yàn)楝F(xiàn)在，在消費(fèi)者線程翻轉(zhuǎn)隊(duì)列并處理數(shù)據(jù)之后，可能會(huì)立即將值元素添加到隊(duì)列中，因此并非所有項(xiàng)目似乎都被消耗了?，F(xiàn)在的實(shí)際問題是，是否可以避免復(fù)制后備隊(duì)列以獲得性能提升，同時(shí)仍然允許使用無鎖算法原子地更新隊(duì)列的內(nèi)容，從而避免中途丟失一些條目？