gpt4 book ai didi

c++11 atomic的使用详解

转载 作者:qq735679552 更新时间:2022-09-29 22:32:09 26 4
gpt4 key购买 nike

CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章c++11 atomic的使用详解由作者收集整理,如果你对这篇文章有兴趣,记得点赞哟.

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. 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
#include <iostream>
#include <atomic>
#include <vector>
#include <thread>
#include <sstream>
 
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<std:: thread > 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;
}

std::atomic

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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
#include <iostream>
#include <atomic>
#include <vector>
#include <thread>
#include <sstream>
 
std::atomic< bool > 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<std:: thread > 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.

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
#include <iostream>
#include <atomic>
#include <vector>
#include <thread>
#include <sstream>
 
std::atomic< int > 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<int>对象的值,print_foo用于打印atomic<int>对象的值。std::atomic对象的值的读取和写入可使用load和store实现.

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
#include <iostream>
#include <cassert>
#include <atomic>
#include <vector>
#include <unistd.h>
#include <thread>
#include <sstream>
 
std::atomic< int > 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<int>支持++和--的原子操作.

以上就是c++11 atomic的使用详解的详细内容,更多关于c++11 atomic的使用的资料请关注我其它相关文章! 。

原文链接:https://www.cnblogs.com/taiyang-li/p/5914331.html 。

最后此篇关于c++11 atomic的使用详解的文章就讲到这里了,如果你想了解更多关于c++11 atomic的使用详解的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com