学习笔记：acquire-release初步理解

#include <atomic>
#include <thread>
#include <chrono>
#include <vector>
#include <iostream>
#include <algorithm>
#include <cassert>
using namespace std;

atomic<int> g_flag;
int g_payload[10240];

void init(){

//[STORE操作]: 一个庞大耗时的数据处理
std::for_each(g_payload, g_payload+10240, [](int &n){ n=1; });

//安放一个“栅栏”
//第一个作用：禁止本指令之前的store操作被私自移动到本指令之后。
//          这意味着[A操作]不能在本指令之后执行
//          也这意味着[SET操作]这个写操作，不能提前执行于本指令。
//第二个作用：将之前的store操作，commit到主内存
//          这意味着g_payload中的数据不会只停留在CPU二级缓存等机构中，要强制送达到老窝中。
atomic_thread_fence(memory_order_release);

//[SET操作]：发布标志位，表示数据已经准备好了。
//        此操作是原子的，在本程序环境下，意味着另外一个线程只能读到g_flag是0或者1，不可能发生读出奇怪的值
//        memory_order_relaxed意味着不对本指令前后的操作做特殊要求。
g_flag.store(1,memory_order_relaxed);
}

void user()
{
while(true){

//原子的读取标志位，如果标志位被置位，则认为init线程已经把数据送到主内存了
int tmp = g_flag.load(memory_order_relaxed);
if (tmp!=1) continue;

//安放一个“栅栏”
//第一个作用： 禁止[load操作]提前于本指令执行
//           防止后续的load操作读到cache中缓存的数据，可以简单的认为把cache清空
//           这样自然就无法cache命中，而只能从主内存中读取数据
atomic_thread_fence(memory_order_acquire);

//[load操作]
int sum=0;
std::for_each(g_payload, g_payload+10240, [&sum](int &n){ sum+=n; });

assert( sum==10240 );

break;
}
}

void test ()
{
//数据全部初始化
g_flag=0;
std::for_each(g_payload, g_payload+10240, [](int &n){ n=0; });

//启动各线程
thread t1(&user);
thread t2(&init);

t1.join();
t2.join();

std::this_thread::sleep_for(std::chrono::milliseconds(1));
}

int main(){

for (int i=0;i<1000;++i){
test();
}

cout<<"Passed!"<<endl;
return 0;
}