zoukankan      html  css  js  c++  java
  • [转]c# 多线程 Mutex(互斥锁)

    互斥锁(Mutex)

    互斥锁是一个互斥的同步对象,意味着同一时间有且仅有一个线程可以获取它。

    互斥锁可适用于一个共享资源每次只能被一个线程访问的情况

     函数:

    //创建一个处于未获取状态的互斥锁

    Public Mutex();

    //如果ownedtrue,互斥锁的初始状态就是被主线程所获取,否则处于未获取状态

     Public Mutex(bool owned);

     如果要获取一个互斥锁。应调用互斥锁上的WaitOne()方法,该方法继承于Thread.WaitHandle

    它处于等到状态直至所调用互斥锁可以被获取,因此该方法将组织住主调线程直到指定的互斥锁可用,如果不需要拥有互斥锁,用ReleaseMutex方法释放,从而使互斥锁可以被另外一个线程所获取。

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54
    55
    56
    57
    58
    59
    60
    61
    62
    63
    64
    65
    66
    67
    68
    69
    70
    71
    72
    73
    74
    75
    76
    77
    78
    79
    80
    81
    82
    83
    84
    85
    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
      
    using System.Threading;
      
    namespace MyTTCon
    {
        class shareRes
        {
            public static int count = 0;
            public static Mutex mutex = new Mutex();
        }
      
        class IncThread
        {
            int number;
            public Thread thrd;
            public IncThread(string name, int n)
            {
                thrd = new Thread(this.run);
                number = n;
                thrd.Name = name;
                thrd.Start();
            }
            void run()
            {
                Console.WriteLine(thrd.Name + "正在等待 the mutex");
                //申请
                shareRes.mutex.WaitOne();
                Console.WriteLine(thrd.Name + "申请到 the mutex");
                do
                {
                    Thread.Sleep(1000);
                    shareRes.count++;
                    Console.WriteLine("In " + thrd.Name + "ShareRes.count is " + shareRes.count);
                    number--;
                } while (number > 0);
                Console.WriteLine(thrd.Name + "释放 the nmutex");
                //  释放
                shareRes.mutex.ReleaseMutex();
            }
        }
        class DecThread
        {
            int number;
            public Thread thrd;
            public DecThread(string name, int n)
            {
                thrd = new Thread(this.run);
                number = n;
                thrd.Name = name;
                thrd.Start();
            }
            void run()
            {
                Console.WriteLine(thrd.Name + "正在等待 the mutex");
                //申请
                shareRes.mutex.WaitOne();
                Console.WriteLine(thrd.Name + "申请到 the mutex");
                do
                {
                    Thread.Sleep(1000);
                    shareRes.count--;
                    Console.WriteLine("In " + thrd.Name + "ShareRes.count is " + shareRes.count);
                    number--;
                } while (number > 0);
                Console.WriteLine(thrd.Name + "释放 the nmutex");
                //  释放
                shareRes.mutex.ReleaseMutex();
            }
        }
      
        class Program
        {
            static void Main(string[] args)
            {
                IncThread mthrd1 = new IncThread("IncThread thread ", 5);
                DecThread mthrd2 = new DecThread("DecThread thread ", 5);
                mthrd1.thrd.Join();
                mthrd2.thrd.Join();
            }
        }
    }
  • 相关阅读:
    不懂的问题
    自我介绍
    《java程序设计》周结 (8)
    201671010143 201620173《java面向程序》周结
    201671010143 201620172《java程序设计》周结
    201671010143 201620172 《Java程序设计》周结
    201671010143 201620172 《Java程序设计》 初学者对于JAVA的简单认识和了解
    201671010143 20162017《Java程序设计》周结
    本章的知识点 Java 接口
    第三次作业
  • 原文地址:https://www.cnblogs.com/wangshenhe/p/2916436.html
Copyright © 2011-2022 走看看