当前位置:编程学习 > asp >>

.NET 4中的多线程编程之二:共享数据(上)

 

本文侧重实例,关于.NET同步原语的概况介绍,可以参考Overview of Synchronization Primitives .http://msdn.microsoft.com/en-us/library/ms228964.aspx

 

在线程间共享数据有可能会导致竞速状态而发生数据不一致的状态, 例如:

 

namespace TaskParallel

{

    class Account

    {

        public int Balance

        {

            get;

            set;

        }

    }

    class Share

    {

        static void Main(string[] args)

        {

            Account account = new Account { Balance = 0 };

            List<Task> tasks = new List<Task>();

            for (int i = 0; i < 10; i++)

            {

                tasks.Add(Task.Factory.StartNew(() =>

                 {

                     for (int j = 0; j < 1000; j++)

                         account.Balance++;    

                 }));

            }

            Task.WaitAll(tasks.ToArray());

            Console.WriteLine(account.Balance);           

        }

    }

}

这段程序中,一共有10个线程,每个线程将一个整型变量自加1000次,期待的结果最终应该是10000,但是运行这段程序的结果每次都不一样而且总比10000小。原因是完成一个变量自加并不是一个原子操作,忽略具体的机器代码不谈,总体上应该是三步,读取当前值,加1,存回计算值.如果线程1读取到了当前值是0,此时被线程2取代而进入等待状态,线程二读取当前值为0,加1,把1存回,线程1接着运行,加1,把1存回。此时Balance的值是1,而已经有线程1和线程2加了2次,数据不一致发生了。下面介绍.Net提供的线程互斥的方法,其实现原理在操作系统原理类的书上有详细介绍,不再赘述。

 

1. 使用Monitor

为了避免不一致发生,必须保证能够改变共享数据的代码在同一时间只有一个线程在执行,要实现这一点,可以使用C#的lock关键字:

object obj = new object();

for (int i = 0; i < 10; i++)

{

     tasks.Add(Task.Factory.StartNew(() =>

     {

           for (int j = 0; j < 1000; j++)

           {

                 lock (obj)

                 {

                      account.Balance++;

                 }

            }

        }));

}

lock其实是Monitor类的一个包装,要使用更为完整的功能可以使用Monitor类.

2.使用Spin Locking

Spin Locking和Monitor实现的效果相似,但是原理不一样。Spin Locking不阻塞当前线程,而是用一个循环来不断判断是否符合访问条件。当预期阻塞的时间不太长的时候,他比Monitor类高效,但是不适合需要长时间阻塞的情况.

SpinLock locker = new SpinLock();           

for (int i = 0; i < 10; i++)

{

     tasks.Add(Task.Factory.StartNew(() =>

     {

          for (int j = 0; j < 1000; j++)

          {

               bool lockAcquired = false;

               try

               {

                   locker.Enter(ref lockAcquired);

                   account.Balance++;

               }

               finally

               {

                    locker.Exit();

               }                      

           }

       }));

}

3.使用Mutex,Semaphore

Mutex,Semaphore都继承自WaitHandle类,可以实现线程互斥的。WaitHandle是windows的synchronization handles的包装。

先介绍Mutex的例子:

Mutex mutex = new Mutex();

for (int i = 0; i < 10; i++)

{

     tasks.Add(Task.Factory.StartNew(() =>

     {

         for (int j = 0; j < 1000; j++)

         {

              bool lockAcquired = mutex.WaitOne();

              account.Balance++;      

              if(lockAcquired)

                 mutex.ReleaseMutex(); 

          }

     }));

}

WaitHandle的WaitAll方法可以同时获得多个锁,例如在下面的程序中,有两个账户,需要两个锁来保持他们在同一时间只有一个线程访问。其中第三个线程同时访问这两个账户,因此需要同时获得这个两个账户的锁,当第三个线程结束访问的时候,要记得释放两个锁。

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading;<

补充:Web开发 , ASP.Net ,
CopyRight © 2022 站长资源库 编程知识问答 zzzyk.com All Rights Reserved
部分文章来自网络,