菜鸟笔记
提升您的技术认知

c 11新特性之atomic-ag真人游戏

  1. std::atomic_flag

  std::atomic_flag是一个原子的布尔类型,可支持两种原子操作:

  • test_and_set, 如果atomic_flag对象被设置,则返回true; 如果atomic_flag对象未被设置,则设置之,返回false
  • clear. 清楚atomic_flag对象

  std::atomic_flag可用于多线程之间的同步操作,类似于linux中的信号量。使用atomic_flag可实现mutex.

#include 
#include 
#include 
#include 
#include 
std::atomic_flag lock = atomic_flag_init;
std::stringstream stream;
void append_numer(int x)
{
  while (lock.test_and_set());
  stream << "thread#" << x << "\n";
  lock.clear();
}
int main()
{
  std::vector ths;
  for (int i=0; i<10; i  )
    ths.push_back(std::thread(append_numer, i));
  for (int i=0; i<10; i  )
    ths[i].join();
  std::cout << stream.str();
  return 0;
}

  2. std::atomic

  std::atomic对int, char, bool等数据结构进行原子性封装,在多线程环境中,对std::atomic对象的访问不会造成竞争-冒险。利用std::atomic可实现数据结构的无锁设计。

#include 
#include 
#include 
#include 
#include 
std::atomic ready(false);
std::atomic_flag winner = atomic_flag_init;
void count1m(int i)
{
  while (!ready);
  for (int i=0; i<1000000; i  );
  if (!winner.test_and_set())
    std::cout << "winner: " << i << std::endl;
}
int main()
{
  std::vector ths;
  for (int i=0; i<10; i  )
    ths.push_back(std::thread(count1m, i));
  ready = true;
  for (int i=0; i<10; i  )
    ths[i].join();
  return 0;
}

  在上例中,执行read=true之后,所有线程结束空等。winner被初始化为atomic_flag_init,最先执行winner.test_and_set并返回false的线程为winner。

#include 
#include 
#include 
#include 
#include 
std::atomic foo(0);
void set_foo(int x)
{
  foo = x;
}
void print_foo()
{
  while (foo == 0)
  {
    std::this_thread::yield();
  }
  std::cout << "x: " << foo << std::endl;
}
int main()
{
  std::thread print_th(print_foo);
  std::thread set_th(set_foo, 10);
  print_th.join();
  set_th.join();
  return 0;
}

  在上例总,set_foo用于设置atomic对象的值,print_foo用于打印atomic对象的值。std::atomic对象的值的读取和写入可使用load和store实现。

#include 
#include 
#include 
#include 
#include 
#include 
#include 
std::atomic foo(0);
std::atomic_flag lock = atomic_flag_init;
void add_foo()
{
  while (1) 
  {
    foo  ;
    // foo = foo   1;
    while (lock.test_and_set());
    std::cout <<"add: " << foo << std::endl;
    lock.clear();
    usleep(1000);
  }
}
void sub_foo()
{
  while (1) 
  {
    foo--;
    // foo = foo - 1;
    while (lock.test_and_set());
    std::cout << "sub: " << foo << std::endl;
    lock.clear();
    usleep(1000);
  }
}
int main()
{
  std::thread th2 = std::thread(add_foo);
  std::thread th1 = std::thread(sub_foo);
  th1.join();
  th2.join();
  return 0;
}

  atomic支持 和--的原子操作。

网站地图