#include <iostream>
#include<thread>
#include<atomic>
#include<vector>
std::atomic<int>count(0);
std::vector<int>queue_data;
//如果存储操作被标记为memory_order_release、memory_order_acq_rel或memory_order_seq_cst，
// 加载操作被标记为memory_order_consume、memory_order_acquire或memory_order_seq_cst，
// 并且链中的每个操作都加载了前一个操作写入的值，那么这一连串的操作构成了一个释放序列。
// 链中的任何原子读 - 修改 - 写操作都可以有任何内存排序（甚至是memory_order_relaxed）//填充队列
void populate_queue_items() {unsigned const number_of_items = 100;queue_data.clear(); //每次填充队列时清空一下for (int i = 0; i < number_of_items; ++i) {queue_data.push_back(i);}count.store(number_of_items, std::memory_order_release); //使用release模式填充原子变量
}
void process_queue_items(const int& item_index) {std::cout << "获得数据：" << queue_data.at(item_index - 1) << "\n";std::this_thread::sleep_for(std::chrono::milliseconds(100));
}
//消费数据
void consume_queue_items() {while (true) {int item_index;//使用acquire和上面的release同步，并且自身+1，这是一个释放操作、获取操作//count减到0为止，然后重新开始获得数据if ((item_index = count.fetch_sub(1, std::memory_order_acq_rel)) <= 0) { //多次释放、获取形成了一条释放获取链std::cout << "等待数据准备中……\n";std::this_thread::sleep_for(std::chrono::microseconds(1));std::thread t(populate_queue_items);t.detach();continue;}process_queue_items(item_index); //使用数据}
}
void Test() {std::thread t(consume_queue_items);t.join();
}
int main(){Test();return 0;
}
