C#线程优先级与状态管理Monitor.Wait和Monitor.Pulse

鸿翔机器人

1. internal class Program
   
2. {
   
3.      static void Main(string[] args)
   
4.      {
   
5.          Demo01();
   
6.          Console.ReadLine();
   
7.      }
   
8. 
   
9.      static object _lock = new object();
   
10.      static bool _running;
    
11.      static void Demo01()
    
12.      {
    
13.          Console.WriteLine($"当前进程优先级：{Process.GetCurrentProcess().PriorityClass}");
    
14. 
    
15.          var lowthread = new Thread(() =>
    
16.          {
    
17.              Console.WriteLine($"低优先级的任务启动：{Thread.CurrentThread.ManagedThreadId}");
    
18.              lock (_lock)
    
19.              {
    
20.                  var oldPri = Thread.CurrentThread.Priority;
    
21.                  Thread.CurrentThread.Priority = ThreadPriority.Highest;
    
22. 
    
23.                  Thread.Sleep(10);
    
24.    
    
25.                  Console.WriteLine("低优先级释放锁");
    
26.                  Thread.CurrentThread.Priority = oldPri;
    
27.              }
    
28.          })
    
29.          {
    
30.              Priority = ThreadPriority.Lowest
    
31.          };
    
32. 
    
33.          var highthread = new Thread(() =>
    
34.          {
    
35.              Console.WriteLine($"高优先级的任务启动：{Thread.CurrentThread.ManagedThreadId}");
    
36.              var stopwatch = Stopwatch.StartNew();
    
37.              lock (_lock)
    
38.              {
    
39.                  stopwatch.Stop();
    
40.                  Console.WriteLine($"高优先级活动锁，等待了{stopwatch.ElapsedMilliseconds}ms, 开始执行任务");               
    
41.              }
    
42.          })
    
43.          {
    
44.              Priority = ThreadPriority.Highest
    
45.          };
    
46. 
    
47.          var middlethread = new Thread(() =>
    
48.          {
    
49.              Console.WriteLine($"中优先级的任务启动：{Thread.CurrentThread.ManagedThreadId}");
    
50.              while(!_running)
    
51.              {
    
52.                  for (int i = 0; i < 100000; i++)
    
53.                  {
    
54.                      Math.Sqrt(i);
    
55.                  }
    
56.              }
    
57.          })
    
58.          {
    
59.              Priority = ThreadPriority.AboveNormal
    
60.          };
    
61. 
    
62.          lowthread.Start();
    
63.          Thread.Sleep(100);
    
64. 
    
65.          highthread.Start();
    
66.          middlethread.Start();
    
67. 
    
68.          highthread.Join();
    
69.          lock (_lock)
    
70.          {
    
71.              Monitor.Pulse(_lock);
    
72.          }
    
73.          _running = true;
    
74. 
    
75.          middlethread.Join();
    
76.         lowthread.Join();
    
77. 
    
78.          Console.WriteLine("结束");
    
79.      }
    
80. 
    
81.      static object obj = new object();
    
82.      static void Demo02()
    
83.      {
    
84.          for(int i=0; i < 6; i++)
    
85.          {
    
86.              Thread thread = new Thread(() =>
    
87.              {
    
88.                  LockMethod();
    
89.              })
    
90.              { Name = $"线程{i}" };
    
91.              thread.Start();
    
92.          }
    
93. 
    
94.          Thread.Sleep(10000);
    
95. 
    
96.          PulseMethod();
    
97.      }
    
98. 
    
99.      public static void LockMethod()
    
100.      {
     
101.          Console.WriteLine(Thread.CurrentThread.Name + "将要进入lock");
     
102. 
     
103.          lock(obj)
     
104.          {
     
105.              Console.WriteLine(Thread.CurrentThread.Name + "进入lock");
     
106.         
     
107.              Thread.Sleep(1000);
     
108.              Monitor.Wait(obj);
     
109.              Console.WriteLine(Thread.CurrentThread.Name + "退出lock");
     
110.          }
     
111.      }
     
112. 
     
113.      public static void PulseMethod()
     
114.      {
     
115.          lock(obj)
     
116.          {
     
117.              Monitor.Pulse(obj);
     
118.             // Monitor.PulseAll(obj);
     
119.          }
     
120.      }
     
121. }

复制代码

参考链接：https://www.dongchuanmin.com/csharp/2889.html