线程同步傻问题:该被同步的变量没有用信号量控制,值是否会被改变

简介:

线程同步傻问题:该被同步的变量没有用信号量控制,值是否会被改变

复制代码
 1 using System;
 2 using System.Collections.Generic;
 3 using System.Linq;
 4 using System.Text;
 5 using System.Threading;
 6 
 7 namespace testLockList
 8 {
 9     class Program
10     {
11 
12         const int ThreadMaxNum = 5;               //要启动的线程的最大数目
13         static void Main(string[] args)
14         {
15             TestList myList = new TestList();
16             for (int i = 0; i < ThreadMaxNum; i++)//同时建立ThreadMaxNum个进程,   
17             {                                     //调用Add方法,看锁住了List,是否能对List里面的单个元素进行修改
18                 Thread myth = new Thread(TestList.add);
19                 myth.Name = string.Format("线程{0}", i);
20                 myth.IsBackground = true;
21                 myth.Start();
22             }          
23             while (TestList.AddInvokeCount != 5)
24             {
25                 Thread.Sleep(500);
26             }
27 
28         }
29     }
30 
31     public class TestList
32     {
33         static List<tester> myList = new List<tester>();//一个List
34         public static int AddInvokeCount = 0;           //用于记录Add被调用的次数
35         public TestList()                               
36         {                                               
37             myList.Add(new tester(0, 0));               //保证第一个元素有值,为了后面取出第一个元素不出错
38         }
39         /// <summary>
40         /// 这个方法用来测试,被锁住的List是否可以被改变值,如果changeValue方法里面没有进行同步
41         /// </summary>
42         static public void changeValue()
43         {
44             tester valueToChange = myList[0];//取出第一个元素
45             valueToChange.a = 111;           //这里改变List中元素的值
46             Console.WriteLine(string.Format("第一个元素被改变的值:{0}",valueToChange.a));
47         }
48         static public void add()
49         {
50             lock (myList)
51             {
52                 int Num = myList.Count + 1;
53                 Thread.Sleep(1000); //保证线程等待
54                 myList.Add(new tester(Num, Num));
55                 if (AddInvokeCount == 1)  //在myMutex未被释放的情况下,changeValue函数里面没有用信号量进行访问控制,
56                 {                         //用另一个线程执行changeValue,看是否可以访问被信号量锁住的变量。
57                     Thread changeValueThread = new Thread(TestList.changeValue);
58                     changeValueThread.Start();
59                     Console.WriteLine("线程等待3秒,保证myList被锁住");
60                     Thread.Sleep(3000); //保证线程等待
61                 }
62                 Console.WriteLine("线程{0}:增加", Thread.CurrentThread.Name);
63                 AddInvokeCount++;   //add函数被调用的次数+1
64             }
65         }
66     }
67     /// <summary>
68     /// 这个类只是用于测试
69     /// </summary>
70     public class tester
71     {
72        public int a;
73        public int b;
74         public tester(int a, int b)
75         {
76             this.a = a;
77             this.b = b;
78         }
79     }
80 }
复制代码

执行结果是:changeValue函数在线程1执行的过程中,没有发送阻塞,等待线程1执行完,而是直接执行。所以没有进行同步控制的函数可以修改被同步控制的值,如图1。

图1 没有进行同步控制的函数可以修改被同步控制的值

 下面修改一下chageValue函数,其他部分不变

复制代码
1         static public void changeValue()
2         {
3             lock (myList)                    //进行同步控制
4             {
5                 tester valueToChange = myList[0];//取出第一个元素
6                 valueToChange.a = 111;           //这里改变List中元素的值
7                 Console.WriteLine(string.Format("第一个元素被改变的值:{0}", valueToChange.a));
8             }
9         }
复制代码

执行结果,如图2。从结果中看出,如果进行同步,则changeValue函数会发生阻塞,直至他可以锁定myList。

图2 进行同步控制的函数会阻塞

本文转自陈哈哈博客园博客,原文链接http://www.cnblogs.com/kissazi2/archive/2013/01/02/2841866.html如需转载请自行联系原作者


kissazi2

相关文章
|
2月前
|
编解码 数据安全/隐私保护 计算机视觉
Opencv学习笔记(十):同步和异步(多线程)操作打开海康摄像头
如何使用OpenCV进行同步和异步操作来打开海康摄像头,并提供了相关的代码示例。
127 1
Opencv学习笔记(十):同步和异步(多线程)操作打开海康摄像头
|
5天前
|
Java 程序员 调度
【JavaEE】线程创建和终止,Thread类方法,变量捕获(7000字长文)
创建线程的五种方式,Thread常见方法(守护进程.setDaemon() ,isAlive),start和run方法的区别,如何提前终止一个线程,标志位,isinterrupted,变量捕获
|
1月前
|
Java 调度
Java 线程同步的四种方式,最全详解,建议收藏!
本文详细解析了Java线程同步的四种方式:synchronized关键字、ReentrantLock、原子变量和ThreadLocal,通过实例代码和对比分析,帮助你深入理解线程同步机制。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
Java 线程同步的四种方式,最全详解,建议收藏!
|
2月前
|
安全 Java 开发者
Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用
本文深入解析了Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用。通过示例代码展示了如何正确使用这些方法,并分享了最佳实践,帮助开发者避免常见陷阱,提高多线程程序的稳定性和效率。
56 1
|
2月前
|
运维 API 计算机视觉
深度解密协程锁、信号量以及线程锁的实现原理
深度解密协程锁、信号量以及线程锁的实现原理
50 2
|
2月前
|
安全 调度 C#
STA模型、同步上下文和多线程、异步调度
【10月更文挑战第19天】本文介绍了 STA 模型、同步上下文和多线程、异步调度的概念及其优缺点。STA 模型适用于单线程环境,确保资源访问的顺序性;同步上下文和多线程提高了程序的并发性和响应性,但增加了复杂性;异步调度提升了程序的响应性和资源利用率,但也带来了编程复杂性和错误处理的挑战。选择合适的模型需根据具体应用场景和需求进行权衡。
|
2月前
多线程通信和同步的方式有哪些?
【10月更文挑战第6天】
139 0
|
2月前
|
安全 Linux
Linux线程(十一)线程互斥锁-条件变量详解
Linux线程(十一)线程互斥锁-条件变量详解
|
7天前
|
NoSQL Redis
单线程传奇Redis,为何引入多线程?
Redis 4.0 引入多线程支持,主要用于后台对象删除、处理阻塞命令和网络 I/O 等操作,以提高并发性和性能。尽管如此,Redis 仍保留单线程执行模型处理客户端请求,确保高效性和简单性。多线程仅用于优化后台任务,如异步删除过期对象和分担读写操作,从而提升整体性能。
26 1
|
2月前
|
存储 消息中间件 资源调度
C++ 多线程之初识多线程
这篇文章介绍了C++多线程的基本概念,包括进程和线程的定义、并发的实现方式,以及如何在C++中创建和管理线程,包括使用`std::thread`库、线程的join和detach方法,并通过示例代码展示了如何创建和使用多线程。
60 1