zoukankan      html  css  js  c++  java
  • c# 线程信号量 Mutex

    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();
                Console.ReadKey();
            }
        }
    }
  • 相关阅读:
    Redis分布式锁解决抢购问题
    Linux查看进程,端口,服务路径等
    执行jar包,输出信息到文件
    查看linux服务器信息
    IDEA将项目打包为指定class文件的jar
    RSA加密-解密以及解决超长内容加密失败解决
    win10 Snipaste 截图软件
    线程池参数详解
    本地连接Linux工具
    python安装
  • 原文地址:https://www.cnblogs.com/kexb/p/6087363.html
Copyright © 2011-2022 走看看