快捷導(dǎo)航

C++11并發(fā)編程關(guān)于原子操作atomic的代碼示例

更新時(shí)間：2018年12月22日 11:37:27 作者：蝸牛201

今天小編就為大家分享一篇關(guān)于C++11并發(fā)編程關(guān)于原子操作atomic的代碼示例，小編覺得內(nèi)容挺不錯(cuò)的，現(xiàn)在分享給大家，具有很好的參考價(jià)值，需要的朋友一起跟隨小編來看看吧

一：概述

項(xiàng)目中經(jīng)常用遇到多線程操作共享數(shù)據(jù)問題，常用的處理方式是對共享數(shù)據(jù)進(jìn)行加鎖，如果多線程操作共享變量也同樣采用這種方式。

為什么要對共享變量加鎖或使用原子操作？如兩個(gè)線程操作同一變量過程中，一個(gè)線程執(zhí)行過程中可能被內(nèi)核臨時(shí)掛起，這就是線程切換，當(dāng)內(nèi)核再次切換到該線程時(shí)，之前的數(shù)據(jù)可能已被修改，不能保證原子操作。

C++11提供了個(gè)原子的類和方法atomic，保證了多線程對變量原子性操作，相比加鎖機(jī)制mutex.lock()，mutex.unlock()，性能有幾倍的提升。

所需頭文件<atomic>

二：錯(cuò)誤代碼

//全局變量
int g_num = 0;
void fun()
{
  for (int i = 0; i < 10000000; i++)
  {
    g_num++;
  }
  return ;
}
int main()
{
  //創(chuàng)建線程1
  thread t1(fun);
  //創(chuàng)建線程2
  thread t2(fun);
  t1.join();
  t2.join();
  cout << g_num << endl;
  getchar();
  return 1;
}

應(yīng)該輸出結(jié)果20000000，實(shí)際每次結(jié)果都不一樣，總是小于該值，正是由于多線程操作同一變量而沒有保證原子性導(dǎo)致的。

三：加鎖代碼

//全局變量
int g_num = 0;
mutex m_mutex;
void fun()
{
  for (int i = 0; i < 10000000; i++)
  {
    m_mutex.lock();
    g_num++;
    m_mutex.unlock();
  }
  return ;
}
int main()
{
  //獲取當(dāng)前毫秒時(shí)間戳
  typedef chrono::time_point<chrono::system_clock, chrono::milliseconds> microClock_type;
  microClock_type tp1 = chrono::time_point_cast<chrono::milliseconds>(chrono::system_clock::now());
  long long time1 = tp1.time_since_epoch().count();
  //創(chuàng)建線程
  thread t1(fun);
  thread t2(fun);
  t1.join();
  t2.join();
  cout << "總數(shù)：" << g_num << endl;
  //獲取當(dāng)前毫秒時(shí)間戳
  microClock_type tp2 = chrono::time_point_cast<chrono::milliseconds>(chrono::system_clock::now());
  long long time2 = tp2.time_since_epoch().count();
  cout << "耗時(shí)：" << time2 - time1 << "ms" << endl;
  getchar();
  return 1;
}

執(zhí)行結(jié)果：多次測試輸出均為20000000，耗時(shí)在3.8s左右

四：atomic原子操作代碼

//全局變量
atomic<int> g_num = 0;
void fun()
{
  for (int i = 0; i < 10000000; i++)
  {
    g_num++;
  }
  return ;
}
int main()
{
  //獲取當(dāng)前毫秒時(shí)間戳
  typedef chrono::time_point<chrono::system_clock, chrono::milliseconds> microClock_type;
  microClock_type tp1 = chrono::time_point_cast<chrono::milliseconds>(chrono::system_clock::now());
  long long time1 = tp1.time_since_epoch().count();
  //創(chuàng)建線程
  thread t1(fun);
  thread t2(fun);
  t1.join();
  t2.join();
  cout << "總數(shù)：" << g_num << endl;
  //獲取當(dāng)前毫秒時(shí)間戳
  microClock_type tp2 = chrono::time_point_cast<chrono::milliseconds>(chrono::system_clock::now());
  long long time2 = tp2.time_since_epoch().count();
  cout << "耗時(shí)：" << time2 - time1 << "ms" << endl;
  getchar();
  return 1;
}

執(zhí)行結(jié)果：多次測試輸出均為20000000，耗時(shí)在1.3s左右