日韩av黄I国产麻豆传媒I国产91av视频在线观看I日韩一区二区三区在线看I美女国产在线I麻豆视频国产在线观看I成人黄色短片

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 >

线程同步monitor

發布時間:2025/6/17 52 豆豆
生活随笔 收集整理的這篇文章主要介紹了 线程同步monitor 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

本文用經典的生產者消費者的例子,說明Mnitor對象的用法。實現的目標是:

生產者生產一個數據,然后消費者開始消費,消費完成后生產者繼續生產,循環10次后結束。

下面是代碼:

? ? namespace ConsoleTest
? ?{
? ? /// <summary>
? ? /// 生產者消費者例子
? ? /// </summary>
? ?public class Producer_Consumer
? ? {
? ? ? ?/// <summary>
? ? ? ?/// 生產者生產數據
? ? ? ?/// </summary>
? ? ? ?private void produce()
? ? ? ?{
? ? ? ? ? ?for (int i = 0; i < 10;i++ )
? ? ? ? ? ?{
? ? ? ? ? ? ? ?try
? ? ? ? ? ? ? ?{
? ? ? ? ? ? ? ? ? ?Monitor.Enter(_locker);?//在調用Wait方法前必須獲取對象的鎖
? ? ? ? ? ? ? ??? ?{
? ? ? ? ? ? ? ? ? ? ? ?Monitor.Wait(_locker);?//阻塞當前線程,釋放鎖,進入等待狀態
? ? ? ? ? ? ? ? ? ??? ?Thread.Sleep(500);?//此處是為了讓程序的執行過程更清楚
? ? ? ? ? ? ? ? ? ? ???_count++;
? ? ? ? ? ? ? ? ? ? ? ?Console.WriteLine("生產者: " + _count);
? ? ? ? ? ? ? ? ? ? ? ?Monitor.Pulse(_locker);?//通知等待獲取鎖(即調用Wait方法的線程)的消費者線程進入就緒狀態
? ? ? ? ? ? ? ? ? ?}
? ? ? ? ? ? ? ?}
? ? ? ? ? ? ? ?finally
? ? ? ? ? ? ? ?{
? ? ? ? ? ? ? ? ? ?Monitor.Exit(_locker);?//釋放鎖
? ? ? ??? ? ? ?}

? ? ? ? ? ?}

? ? ? ?}

? ? ? ?/// <summary>
? ? ? ?/// 消費者消費數據
? ? ? ?/// </summary>
? ? ? ?private void consume()
? ? ? ?{
? ? ? ? ? ?try
? ? ? ? ? ?{
? ? ? ? ? ? ? ?Monitor.Enter(_locker);?//在調用Pulse方法前必須獲取對象的鎖
? ? ? ? ? ? ???{
? ? ? ? ? ? ? ? ? ?Monitor.Pulse(_locker);?//此處不加這句代碼會造成死鎖
? ? ? ? ? ? ? ??? ?while (Monitor.Wait(_locker))?//循環等待生產者線程生產數據完成
? ??? ? ? ? ? ? ? ?{
? ? ? ? ? ? ? ? ? ? ? ?Thread.Sleep(500);
? ? ? ? ? ? ? ? ? ? ? ?Console.WriteLine("消費者:" + _count);
? ? ? ? ? ? ? ? ? ? ???Monitor.Pulse(_locker);?//消費完成后,通知生產者繼續生產
? ? ??? ? ? ? ? ? ? ? ?if (_count == 10)
? ? ? ? ? ? ? ? ? ? ? ?{
? ? ? ? ? ? ? ? ? ? ? ? ? ?Console.ReadLine();
? ? ? ? ? ? ? ? ? ? ? ? ? ?return;?//消費完10個數據后程序退出
? ? ? ? ? ? ? ? ? ? ? ?}
? ? ? ? ? ? ? ? ? ?}
? ? ? ? ? ? ? ?}
? ? ? ? ? ?}
? ? ? ? ? ?finally
? ? ? ? ? ?{
? ? ? ? ? ? ? ?Monitor.Exit(_locker);//釋放鎖
? ? ? ? ? ?}
? ? ? ?}

? ? ? ?public void Test()
? ? ? ?{
? ? ? ? ? ?Thread thread1 = new Thread(produce);
? ? ? ? ? ?Thread thread2 = new Thread(consume);

? ? ? ? ? ?thread1.Start();
? ? ? ? ? ?thread2.Start();
? ? ? ?}

? ? ? ?private int _count;
? ? ? ?private object _locker = new object();
? ? ? ?}
? ? }

? ??代碼中有幾個地方需要注意:

? ? 1、Monitor.Enter(object)方法是獲取鎖,Monitor.Exit(object)方法是釋放鎖,為了避免在獲取鎖后發

? ? ? ? ?生異常,導致鎖無法釋放,所以要在finally塊中釋放鎖。經常用的lock(object){}其實是用如下方式實現的:

? ? ?try{

? ? ? ? ?Monitor.Enter(object);

? ? ? ? //do something

? ? ? ? ?}

? ? ? finally{

? ? ? ??Monitor.Exit(object);

? ? ? }

? ? 2、Monitor.Pluse(object)調用后,程序不會立即轉向Minitor.Wait(object)執行,

它只是讓Wait的線程進入就緒狀態,獲得執行的可能性。

轉載于:https://www.cnblogs.com/yangyuan33/p/7458552.html

總結

以上是生活随笔為你收集整理的线程同步monitor的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。