锁本身也是线程 安全的

时间:2021-12-22 02:39:05

一. 为什么要lock,lock了什么?

当我们使用线程的时候,效率最高的方法固然是异步,即各个线程同时运行,其间不彼此依赖和期待。但当差此外线程都需要访谒某个资源的时候,就需要同步机制了,也就是说当对同一个资源进行读写的时候,我们要使该资源在同一时刻只能被一个线程操纵,以确保每个操纵都是有效即时的,也即保证其操纵的原子性。lock是C#中最常用的同步方法,格局为lock(objectA){codeB} 。


lock(objectA){codeB} 看似简单,实际上有三个意思,这对付适当地使用它至关重要:
1. objectA被lock了吗?没有则由我来lock,否则一直期待,直至objectA被释放。
2. lock以后在执行codeB的期间其他线程不能挪用codeB,也不能使用objectA。
3. 执行完codeB之后释放objectA,并且codeB可以被其他线程访谒。


二. lock(this)怎么了?


我们看一个例子:

using System;

using System.Threading;

namespace Namespace1

{

    class C1

    {

        private bool deadlocked = true;

        //这个要领用到了lock,我们但愿lock的代码在同一时刻只能由一个线程访谒

        public void LockMe(object o)

        {

            lock (this)

            {

                while(deadlocked)

                {

                    deadlocked = (bool)o;

                    Console.WriteLine("Foo: I am locked :(");

                    Thread.Sleep(500);

                }

            }

        }

        //所有线程都可以同时访谒的要领

        public void DoNotLockMe()

        {

            Console.WriteLine("I am not locked :)");

        }

    }

    class Program

    {

        static void Main(string[] args)

        {

            C1 c1 = new C1();

            //在t1线程中挪用LockMe,并将deadlock设为true(将呈现死锁)

            Thread t1 = new Thread(c1.LockMe);

            t1.Start(true);

            Thread.Sleep(100);

            //在主线程中lock c1

            lock (c1)

            {

                //挪用没有被lock的要领

                c1.DoNotLockMe();

                //挪用被lock的要领,并试图将deadlock解除

                c1.LockMe(false);

            }

        }

    }

复制代码

在t1线程中,LockMe挪用了lock(this), 也就是Main函数中的c1,这时候在主线程中挪用lock(c1)时,必需要期待t1中的lock块执行完毕之后才华访谒c1,即所有c1相关的操纵都无法完成,于是我们看到连c1.DoNotLockMe()都没有执行。


把C1的代码稍作窜改:

    class C1

    {

        private bool deadlocked = true;

        private object locker = new object();

        //这个要领用到了lock,我们但愿lock的代码在同一时刻只能由一个线程访谒

        public void LockMe(object o)

        {

            lock (locker)

            {

                while(deadlocked)

                {

                    deadlocked = (bool)o;

                    Console.WriteLine("Foo: I am locked :(");

                    Thread.Sleep(500);

                }

            }

        }

        //所有线程都可以同时访谒的要领

        public void DoNotLockMe()

        {

            Console.WriteLine("I am not locked :)");

        }

    }

复制代码