独望枫

人在尘世间,有缘自相见,变化千千万,未开窍,已迷恋
posts - 43, comments - 0, trackbacks - 0, articles - 1
  C++博客 :: 首页 :: 新随笔 :: 联系 :: 聚合  :: 管理

RT-Thread Nano 线程间同步之互斥量

Posted on 2021-07-14 01:06 小菜枫 阅读(109) 评论(0)  编辑 收藏 引用 所属分类: 学习笔记
访问同一数据,没有使用线程同步的情况下,可能会导致一些数据的变化不是我们所期望的,如下举个例子:
未使用互斥量进行线程间同步的线程:
 1 rt_thread_t sampleThread1;
 2 rt_thread_t sampleThread2;
 3 int SampleTaskCreate(void)
 4 {
 5 sampleThread1 = rt_thread_create("sampleThread1",
 6 AddThread1_entery,
 7 RT_NULL,
 8 256,
 9 4,
10 10);
11 if (sampleThread1 != RT_NULL)
12 {
13 rt_thread_startup(sampleThread1);
14 }
15 else
16 {
17 return 0;
18 }
19 
20 sampleThread2 = rt_thread_create("sampleThread2",
21 AddThread2_entery,
22 RT_NULL,
23 256,
24 2,
25 10);
26 if (sampleThread2 != RT_NULL)
27 {
28 rt_thread_startup(sampleThread2);
29 return 1;
30 }
31 return 0;
32 }
33 INIT_APP_EXPORT(SampleTaskCreate);
34 
35 static uint8_t number1, number2 = 0;
36 void AddThread1_entery(void* parameter)
37 {
38 while(1)
39 {
40 number1++;
41 rt_thread_mdelay(100);
42 number2++;
43 }
44 }
45 
46 void AddThread2_entery(void* parameter)
47 {
48 while(1)
49 {
50 if (number1 != number2)
51 {
52 rt_kprintf("\r\nnumer1(%d) != number2(%d)", number1, number2);
53 }
54 else
55 {
56 rt_kprintf("\r\nnumer1 == number2, is %d", number1);
57 }
58 number1++;
59 number2++;
60 rt_thread_mdelay(1000);
61 }
62 }

其运行结果如下:
numer1 == number2, is 0msh >
numer1(11) != number2(10)
numer1(22) != number2(21)
numer1(33) != number2(32)
numer1(44) != number2(43)
numer1(55) != number2(54)
numer1(66) != number2(65)
numer1(77) != number2(76)
numer1(88) != number2(87)
numer1(99) != number2(98)
numer1(110) != number2(109)
numer1(121) != number2(120)
numer1(132) != number2(131)
numer1(143) != number2(142)
numer1(154) != number2(153)
numer1(165) != number2(164)
numer1(176) != number2(175)
numer1(187) != number2(186)
numer1(198) != number2(197)
numer1(209) != number2(208)
numer1(220) != number2(219)
numer1(231) != number2(230)
numer1(242) != number2(241)
numer1(253) != number2(252)
numer1(8) != number2(7)
numer1(19) != number2(18)
numer1(30) != number2(29)
numer1(41) != number2(40)
numer1(52) != number2(51)
numer1(63) != number2(62)
numer1(74) != number2(73)

可以看到第一次进入thread2时,两个值是相等的,但是后面就不相等了,因为thread1中两个变量的自增中间有明显的延时,导致number1自增完后,线程1挂起,运行线程2,此时number2尚未自增,所以number2就一直都比number1小


启用互斥量进行同步
1、互斥量默认关闭,如果需要使用互斥量,则需要在rtconfig.h头文件开启对应的宏定义


2、声明并创建互斥量


3、动态创建两个跟上述基本一样的线程,只是多了互斥量的引用



4、编译通过,烧写


5、验证:两个变量一直保持同步自增


------------------------↑动态创建----静态初始化↓-----------------------

直接上代码,这里只是静态创建互斥量和线程,其他跟上面动态创建的一样:


编译烧写验证结果:两个变量一直保持同步自增

只有注册用户登录后才能发表评论。
【推荐】超50万行VC++源码: 大型组态工控、电力仿真CAD与GIS源码库
网站导航: 博客园   IT新闻   BlogJava   知识库   博问   管理