MPMCQueue下載 - MPMCQueue原始碼下載

MPMCQueue

C/C++

1.0.0

下載

MPMC隊列.h

用 C++11 編寫的有界多生產者多消費者並發隊列。

它經過實戰考驗並每天在生產中使用：

在Electronic Arts 為以下遊戲開發的Frostbite 遊戲引擎中：
- 聖歌 (2019)
- 戰地 V (2018)
- 國際足總 18 (2017)
- 《勁爆橄欖球 18》(2017)
- 極品飛車：回報 (2017)
Charlesworth Research 和 Marquette Partners 的低延遲交易基礎設施。

它被以下論文引用：

歐培兆和布萊恩·德姆斯基。 2018 年。過程。 ACM 計劃。郎. 2、OOPSLA，第 136 條（2018 年 10 月），29 頁。 DOI：https://doi.org/10.1145/3276506

例子

MPMCQueue< int > q ( 10 );
auto t1 = std::thread([&] {
  int v;
  q. pop (v);
  std::cout << " t1 " << v << " n " ;
});
auto t2 = std::thread([&] {
  int v;
  q. pop (v);
  std::cout << " t2 " << v << " n " ;
});
q.push( 1 );
q.push( 2 );
t1.join();
t2.join();

用法

MPMCQueue<T>(size_t capacity);
建構一個新的MPMCQueue保存類型為T容量為capacity專案。
void emplace(Args &&... args);
使用就地構造對項目進行排隊。如果隊列已滿則阻塞。
bool try_emplace(Args &&... args);
嘗試使用就地構造對項目進行排隊。成功則傳回true ，如果佇列已滿則傳回false 。
void push(const T &v);
使用複製構造對項目進行排隊。如果隊列已滿則阻塞。
template <typename P> void push(P &&v);
使用移動構造對項目進行排隊。僅當std::is_nothrow_constructible<T, P&&>::value == true時才參與重載決策。如果隊列已滿則阻塞。
bool try_push(const T &v);
嘗試使用複製構造將項目排隊。成功則傳回true ，如果佇列已滿則傳回false 。
template <typename P> bool try_push(P &&v);
嘗試使用移動構造將項目排隊。僅當std::is_nothrow_constructible<T, P&&>::value == true時才參與重載決策。成功則傳回true ，如果佇列已滿則傳回false 。
void pop(T &v);
透過將項目複製或移動到v來使項目出隊。如果佇列為空則阻塞。
bool try_pop(T &v);
嘗試透過將項目複製或移動到v來使項目出隊。成功則傳回true ，如果佇列為空則傳回false 。
ssize_t size();
傳回佇列中的元素數量。
當隊列為空並且至少有一個讀者在等待時，大小可以是負數。由於這是一個並發隊列，因此在所有讀取器和寫入器線程都加入之前，大小只是盡力猜測。
bool empty();
如果隊列為空則傳回 true。
由於這是一個並發隊列，因此在所有讀取器和寫入器線程都已加入之前，這只是盡力猜測。

除了構造和銷毀之外的所有操作都是線程安全的。

執行

記憶體佈局

入隊：

從頭部取得下一張寫票。
等待輪到我們（2 *（門票/容量））寫入插槽（門票％容量）。
設定turn=turn+1來通知讀者我們已經寫完了。

出隊：

從tail取得下一個讀票。
等待輪到我們（2 *（門票/容量）+ 1）來讀取插槽（門票％容量）。
設定turn=turn+1來通知筆者我們已經讀完。

參考：

丹尼爾·奧羅斯科 (Daniel Orozco)、埃爾金·加西亞 (Elkin Garcia)、裡什·汗 (Rishi Khan)、凱利·利文斯頓 (Kelly Livingston) 和高光 (Guang R.Gao) 。 2012 年。 ACM 翻譯。建築師。程式碼優化。 8、4、第 49 條（2012 年 1 月），21 頁。 DOI：https://doi.org/10.1145/2086696.2086728
戴夫·戴斯. 2014. PTLQueue：可擴充的有限容量 MPMC 佇列。
亞歷山大·奧滕科。 US 8607249 B2：用於高效並發隊列實現的系統和方法。
馬西米利亞諾·梅內金、達維德·帕塞托、休伯特·弗蘭克。 2012.多核心/多執行緒架構上執行緒間通訊機制的效能評估。 DOI：https://doi.org/10.1145/2287076.2287098
保羅·E·麥肯尼。 2010。
德米特里·維尤科夫。 2014. 有界 MPMC 佇列。