稳扎稳打Silverlight(26) - 2.0线程之Lock, Interlocked, EventWaitHandle, Monitor, ThreadStaticAttribute

< UserControl  x:Class ="Silverlight20.Thread.Lock"

    xmlns ="http://scheR_81_11845@as.microsoft.com/winfx/2006/xaml/presentation"  

    xmlns:x ="http://scheR_81_11845@as.microsoft.com/winfx/2006/xaml" >

     < StackPanel  HorizontalAlignment ="Left"  Margin ="5" >

         < TextBlock  x:Name ="txtmsg"   />

     </ StackPanel >

</ UserControl >

using  System;

using  System.Collections.Generic;

using  System.Linq;

using  System.Net;

using  System.Windows;

using  System.Windows.Controls;

using  System.Windows.Documents;

using  System.Windows.Input;

using  System.Windows.Media;

using  System.Windows.Media.Animation;

using  System.Windows.Shapes;

namespace  Silverlight20.Thread

{

    public partial class Lock : UserControl

    

{

        @H_635_301@//@H_635_301@ 需要被 lock 的静态变量@H_635_301@

        private static readonly object objLock = new object();

        private static int i;

        public Lock()

        

{

            initializeComponent();

            i = @H_355_404@0;

            for (int x = @H_355_404@0; x < @H_355_404@100; x++)

@H_197_537@

            

{

                @H_635_301@//@H_635_301@ 开 100 个线程去操作静态变量 i@H_635_301@

                System.Threading.Thread thread = new System.Threading.Thread(new System.Threading.ThreadStart(DoWork));

                thread.Start();

            }

            System.Threading.Thread.Sleep(@H_355_404@3000);

            @H_635_301@//@H_635_301@ 3 秒后 100 个线程都应该执行完毕了，取得 i 的结果

            @H_635_301@//@H_635_301@ 做了并发处理的结果为 100 ，去掉 lock 可得到不做并发处理的结果@H_635_301@

            txtmsg.Text = i.ToString();

        }

        private void DoWork()

        @H_154_674@

{

            try

@H_128_696@

            

{

                @H_635_301@//@H_635_301@ lock() - 确保代码块完成运行，而不会被其他线程中断。其参数必须为一个引用类型的对象@H_635_301@

                lock (objLock)

                

{

                    int j = i + @H_355_404@1;

                    @H_635_301@//@H_635_301@ 模拟多线程并发操作静态变量 i 的情况@H_635_301@

                    System.Threading.Thread.Sleep(@H_355_404@10);

                    i = j;

                }

            }

            finally

            

{

                @H_635_301@//@H_635_301@ code@H_635_301@

            }

        }

    }

}

< UserControl  x:Class ="Silverlight20.Thread.Interlocked"

    xmlns ="http://scheR_81_11845@as.microsoft.com/winfx/2006/xaml/presentation"  

    xmlns:x ="http://scheR_81_11845@as.microsoft.com/winfx/2006/xaml" >

     < StackPanel  HorizontalAlignment ="Left"  Margin ="5" >

         < TextBlock  x:Name ="txtmsg"   />

     </ StackPanel >

</ UserControl >

using  System;

using  System.Collections.Generic;

using  System.Linq;

using  System.Net;

using  System.Windows;

using  System.Windows.Controls;

using  System.Windows.Documents;

using  System.Windows.Input;

using  System.Windows.Media;

using  System.Windows.Media.Animation;

using  System.Windows.Shapes;

namespace  Silverlight20.Thread

{

    public partial class Interlocked : UserControl

    

{

        private static int i;

        public Interlocked()

        

{

            initializeComponent();

            i = @H_355_404@0;

            for (int x = @H_355_404@0; x < @H_355_404@100; x++)

            

{

                @H_635_301@//@H_635_301@ 开 100 个线程去操作静态变量 i@H_635_301@

                System.Threading.Thread thread = new System.Threading.Thread(new System.Threading.ThreadStart(DoWork));

                thread.Start();

            }

            System.Threading.Thread.Sleep(@H_355_404@1000);

            @H_635_301@//@H_635_301@ 1 秒后 100 个线程都应该执行完毕了，取得 i 的结果@H_635_301@

            txtmsg.Text = i.ToString();

        }

        private void DoWork()

        @H_792_1489@

{

            try

            

{

                @H_635_301@//@H_635_301@ Interlocked - 为多个线程共享的变量提供原子级的操作（避免并发问题）

                @H_635_301@//@H_635_301@ i 加 1@H_635_301@

                System.Threading.Interlocked.Increment(ref i);

                @H_635_301@//@H_635_301@ i 减 1@H_635_301@

                System.Threading.Interlocked.Decrement(ref i);

                @H_635_301@//@H_635_301@ i 加 1@H_635_301@

                System.Threading.Interlocked.Add(ref i, @H_355_404@1);

                @H_635_301@//@H_635_301@ 如果 i 等于 100 ，则将 i 赋值为 101@H_635_301@

                System.Threading.Interlocked.CompareExchange(ref i, @H_355_404@101, @H_355_404@100); 

                @H_635_301@//@H_635_301@ 将 i 赋值为 1000

                @H_635_301@//@H_635_301@ System.Threading.Interlocked.Exchange(ref i, 1000);@H_635_301@

            }

            finally

            

@H_345_1696@{

                @H_635_301@//@H_635_301@ code@H_635_301@

            }

        }

    }

}

< UserControl  x:Class ="Silverlight20.Thread.EventWaitHandle"

    xmlns ="http://scheR_81_11845@as.microsoft.com/winfx/2006/xaml/presentation"  

    xmlns:x ="http://scheR_81_11845@as.microsoft.com/winfx/2006/xaml" >

     < StackPanel  HorizontalAlignment ="Left"  Margin ="5" >

         < TextBlock  x:Name ="txtAutoResetEvent"   />

        

         < TextBlock  x:Name ="txtManualResetEvent"   />

     </ StackPanel >

</ UserControl >

using  System;

using  System.Collections.Generic;

using  System.Linq;

using  System.Net;

using  System.Windows;

using  System.Windows.Controls;

using  System.Windows.Documents;

using  System.Windows.Input;

using  System.Windows.Media;

using  System.Windows.Media.Animation;

using  System.Windows.Shapes;

namespace  Silverlight20.Thread

@H_801_2043@

{

    public partial class EventWaitHandle : UserControl

    

{

        @H_635_301@//@H_635_301@ AutoResetEvent(bool statE) - 通知其他线程是否可入的类，自动 reset()

        @H_635_301@//@H_635_301@     bool state - 是否为终止状态，即是否禁止其他线程入内@H_635_301@

        private System.Threading.AutoResetEvent autoResetEvent = 

            new System.Threading.AutoResetEvent(false);

        @H_635_301@//@H_635_301@ ManualResetEvent(bool statE) - 通知其他线程是否可入的类，手动 reset()

        @H_635_301@//@H_635_301@     bool state - 是否为终止状态，即是否禁止其他线程入内@H_635_301@

        private System.Threading.ManualResetEvent manualResetEvent = 

            new System.Threading.ManualResetEvent(false);

        private static int i;

        public EventWaitHandle()

        

{

            initializeComponent();

            @H_635_301@//@H_635_301@ 演示 AutoResetEvent@H_635_301@

            AutoResetEventDemo();

            @H_635_301@//@H_635_301@ 演示 ManualResetEvent@H_635_301@

            ManualResetEventDemo();

        }

        private void AutoResetEventDemo()

@H_174_2331@

        

{

            i = @H_355_404@0;

            for (int x = @H_355_404@0; x < @H_355_404@100; x++)

            

{

                @H_635_301@//@H_635_301@ 开 100 个线程去操作静态变量 i@H_635_301@

                System.Threading.Thread thread =

                    new System.Threading.Thread(new System.Threading.ThreadStart(AutoResetEventDemoCallBACk));

                thread.Start();

                @H_635_301@//@H_635_301@ 阻塞当前线程，直到 AutoResetEvent 发出 Set() 信号@H_635_301@

                autoResetEvent.WaitOne();

            }

            System.Threading.Thread.Sleep(@H_355_404@1000);

            @H_635_301@//@H_635_301@ 1 秒后 100 个线程都应该执行完毕了，取得 i 的结果@H_635_301@

            txtAutoResetEvent.Text = i.ToString();

        }

        private void AutoResetEventDemoCallBACk()

        

{

            try

            

{

                int j = i + @H_355_404@1;

                @H_635_301@//@H_635_301@ 模拟多线程并发操作静态变量 i 的情况@H_635_301@

                System.Threading.Thread.Sleep(@H_355_404@5);

                i = j;

            }

            finally

            

{

                @H_635_301@//@H_635_301@ 发出 Set() 信号，以释放 AutoResetEvent 所阻塞的线程@H_635_301@

                autoResetEvent.Set();

            }

        }

        private void ManualResetEventDemo()

        

{

            i = @H_355_404@0;

            for (int x = @H_355_404@0; x < @H_355_404@100; x++)

            

{

                @H_635_301@//@H_635_301@ reset() - 将 ManualResetEvent 变为非终止状态，即由此线程控制 ManualResetEvent，

                @H_635_301@//@H_635_301@     其他线程排队，直到 ManualResetEvent 发出 Set() 信号（AutoResetEvent 在 Set() 时会自动 reset()）@H_635_301@

                manualResetEvent.Reset();

                @H_635_301@//@H_635_301@ 开 100 个线程去操作静态变量 i@H_635_301@

                System.Threading.Thread thread =

                    new System.Threading.Thread(new System.Threading.ThreadStart(ManualResetEventDemoCallBACk));

                thread.Start();

                @H_635_301@//@H_635_301@ 阻塞当前线程，直到 ManualResetEvent 发出 Set() 信号@H_635_301@

                manualResetEvent.WaitOne();

            }

            System.Threading.Thread.Sleep(@H_355_404@1000);

            @H_635_301@//@H_635_301@ 1 秒后 100 个线程都应该执行完毕了，取得 i 的结果@H_635_301@

            txtManualResetEvent.Text = i.ToString();

        }

        private void ManualResetEventDemoCallBACk()

        

{

            try

            

{

                int j = i + @H_355_404@1;

                @H_635_301@//@H_635_301@ 模拟多线程并发操作静态变量 i 的情况@H_635_301@

                System.Threading.Thread.Sleep(@H_355_404@5);

                i = j;

            }

            finally

            

{

                @H_635_301@//@H_635_301@ 发出 Set() 信号，以释放 ManualResetEvent 所阻塞的线程，同时 ManualResetEvent 变为终止状态）@H_635_301@

                manualResetEvent.Set();

            }

        }

    }

}

< UserControl  x:Class ="Silverlight20.Thread.Monitor"

    xmlns ="http://scheR_81_11845@as.microsoft.com/winfx/2006/xaml/presentation"  

    xmlns:x ="http://scheR_81_11845@as.microsoft.com/winfx/2006/xaml" >

     < StackPanel  HorizontalAlignment ="Left"  Margin ="5" >

         < TextBlock  x:Name ="txtmsg"   />

     </ StackPanel >

</ UserControl >

using  System;

using  System.Collections.Generic;

using  System.Linq;

using  System.Net;

using  System.Windows;

using  System.Windows.Controls;

using  System.Windows.Documents;

using  System.Windows.Input;

using  System.Windows.Media;

using  System.Windows.Media.Animation;

using  System.Windows.Shapes;

namespace  Silverlight20.Thread

{

    public partial class Monitor : UserControl

@H_989_3018@

    

{

        private static readonly object objLock = new object();

        private static int i;

        

        public Monitor()

        

{

            initializeComponent();

            i = @H_355_404@0;

            for (int x = @H_355_404@0; x < @H_355_404@100; x++)

            

{

                @H_635_301@//@H_635_301@ 开 100 个线程去操作静态变量 i@H_635_301@

                System.Threading.Thread thread = new System.Threading.Thread(new System.Threading.ThreadStart(DoWork));

                thread.Start();

            }

            System.Threading.Thread.Sleep(@H_355_404@1000);

            @H_635_301@//@H_635_301@ 1 秒后 100 个线程都应该执行完毕了，取得 i 的结果@H_635_301@

            txtmsg.Text = i.ToString();

        }

        private void DoWork()

        

@H_618_3821@{

            try

            

{

                @H_635_301@//@H_635_301@ Monitor - 提供同步访问对象的机制

                @H_635_301@//@H_635_301@ Enter() - 在指定对象上获取排他锁@H_635_301@

                System.Threading.Monitor.Enter(objLock);

                int j = i + @H_355_404@1;

                @H_635_301@//@H_635_301@ 模拟多线程并发操作静态变量 i 的情况@H_635_301@

                System.Threading.Thread.Sleep(@H_355_404@5);

                i = j;

                @H_635_301@//@H_635_301@ Exit() - 释放指定对象上的排他锁@H_635_301@

                System.Threading.Monitor.Exit(objLock);

            }

            finally

            

{

                @H_635_301@//@H_635_301@ code@H_635_301@

            }

        }

    }

}

< UserControl  x:Class ="Silverlight20.Thread.ThreadStaticAttribute"

    xmlns ="http://scheR_81_11845@as.microsoft.com/winfx/2006/xaml/presentation"  

    xmlns:x ="http://scheR_81_11845@as.microsoft.com/winfx/2006/xaml" >

     < StackPanel  HorizontalAlignment ="Left"  Margin ="5" >

    

         < TextBlock  x:Name ="txtmsg"   />

        

         < TextBlock  x:Name ="txtmsg2"   />

     </ StackPanel >

</ UserControl >

using  System;

using  System.Collections.Generic;

using  System.Linq;

using  System.Net;

using  System.Windows;

using  System.Windows.Controls;

using  System.Windows.Documents;

using  System.Windows.Input;

using  System.Windows.Media;

using  System.Windows.Media.Animation;

using  System.Windows.Shapes;

namespace  Silverlight20.Thread

{

    public partial class ThreadStaticAttribute : UserControl

    

{

        @H_635_301@//@H_635_301@ ThreadStatic - 所指定的静态变量对每个线程都是唯一的@H_635_301@

        [System.ThreadStatic]

        private static int value;

        @H_635_301@//@H_635_301@ 一般的静态变量，对每个线程都是共用的@H_635_301@

        private static int value2;

        public ThreadStaticAttribute()

@H_189_4489@

        

@H_256_4500@{

            initializeComponent();

            Demo();

        }

        void Demo()

        

{

            System.Threading.Thread thread = new System.Threading.Thread(DoWork);

            thread.Name = "线程1";

            thread.Start();

            System.Threading.Thread.Sleep(@H_355_404@100);

            System.Threading.Thread thread2 = new System.Threading.Thread(DoWork2);

            thread2.Name = "线程2";

            thread2.Start();

        }

        void DoWork()

@H_424_4696@

        @H_607_4705@

{

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

            

{

                @H_635_301@//@H_635_301@ 线程1对静态变量的操作@H_635_301@

                value++;

                value2++;

            }

            String s = value.ToString(); @H_635_301@//@H_635_301@ value - 本线程独有的静态变量@H_635_301@

            String s2 = value2.ToString(); @H_635_301@//@H_635_301@ value2 - 所有线程共用的静态变量@H_635_301@

            this.Dispatcher.beginInvoke(delegate 

@H_621_4874@{ txtmsg.Text = s + " - " + s2; });

            @H_635_301@//@H_635_301@ this.Dispatcher.beginInvoke(delegate { txtmsg.Text = value + " - " + value2; }); @H_635_301@//@H_635_301@ 在UI线程上调用，所以value值为UI线程上的value值，即 0 @H_635_301@

        }

        void DoWork2()

        

{

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

            

{

                @H_635_301@//@H_635_301@ 线程2对静态变量的操作@H_635_301@

                value++;

                value2++;

            }

            String s = value.ToString(); @H_635_301@//@H_635_301@ value - 本线程独有的静态变量@H_635_301@

            String s2 = value2.ToString(); @H_635_301@//@H_635_301@ value2 - 所有线程共用的静态变量@H_635_301@

@H_618_5093@

            this.Dispatcher.beginInvoke(delegate @H_721_4403@

{ txtmsg2.Text = s + " - " + s2; });

            @H_635_301@//@H_635_301@ this.Dispatcher.beginInvoke(delegate { txtmsg2.Text = value + " - " + value2; }); @H_635_301@//@H_635_301@ 在UI线程上调用，所以value值为UI线程上的value值，即 0 @H_635_301@

        }

    }

}