Bakery Algorithm的c#实现用于多线程互斥访问临界资源

算法原理：每个线程进入的时候都要取得一个编号，对于不同线程编号较小的较先运行，编号相同时进程号小的先运行。

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;namespace Bakery
{class Program{public static int[] data = new int[100000];public static int total = 10;private static object ojb = new object();static int num = 10;static int threads=4;static List<int> ticket = new List<int>(threads); // 保留票号static List<bool> entering = new List<bool>(threads); //记录线程是否要进入public static void addLock(int pid) // thread ID{//Console.WriteLine(pid);entering[pid] = true;int max = 0;for (int i = 0; i < threads; ++i){int current = ticket[i];if (current > max){max = current;}}ticket[pid]=max+1; entering[pid]=false;for (int i = 0; i < ticket.Count; ++i){if (i != pid){while (entering[i] == true) { ; } // wait while other thread picks a ticketwhile (ticket[i] != 0 && ( ticket[pid] > ticket[i]  ||(ticket[pid] == ticket[i] && pid > i))){ ; }}}// The critical section goes here...}public static void unlock(int pid){ticket[pid] = 0;}public static void changeValue(object pid){int p = Convert.ToInt32(pid.ToString());addLock(p);for (int i = 0; i < total; i++){num = num + 1;Console.WriteLine(num);}unlock(p);}public static void readValue(object pid){int p = Convert.ToInt32(pid.ToString());addLock(p);for (int i = 0; i < total; i++){num = num - 1;Console.WriteLine(num);}unlock(p);}static void Main(string[] args){ticket = new List<int>(threads);entering = new List<bool>(threads);for (int i = 0; i < threads;i++ ){ticket.Add(-1);entering.Add(false);}for (int i = 0; i < total; i++){data[i] = 0;}Stopwatch stopwatch = new Stopwatch();stopwatch.Start();int num = 10;Thread[] t = new Thread[num];t[0] = new Thread(new ParameterizedThreadStart(changeValue));t[1] = new Thread(new ParameterizedThreadStart(readValue));t[2] = new Thread(new ParameterizedThreadStart(readValue));t[3] = new Thread(new ParameterizedThreadStart(changeValue));stopwatch.Start();t[0].Start(0);t[1].Start(1);t[2].Start(2);t[3].Start(3);t[0].Join();t[1].Join();t[2].Join();t[3].Join();stopwatch.Stop();Console.WriteLine("运行时间" + stopwatch.ElapsedMilliseconds.ToString());Console.ReadKey();}}
}

Bakery Algorithm的c#实现用于多线程互斥访问临界资源相关推荐

jmu-Java-07多线程-互斥访问 (5分)
6-8 jmu-Java-07多线程-互斥访问 (5分) 定义Account类属性: private int balance 方法: getter方法 void deposit(int money) ...
java复选框互斥_jmu-Java-07多线程-互斥访问 (5分)
6-8 jmu-Java-07多线程-互斥访问 (5分) 定义Account类属性: private int balance 方法: getter方法 void deposit(int money) ...
基于Linux的kfifo移植到STM32（支持os的互斥访问）
基于Linux的kfifo移植到STM32(支持os的互斥访问) 声明:本文为杰杰原创,转载请说明出处 https://blog.csdn.net/jiejiemcu/article/details/ ...
C++11多线程---互斥量、锁、条件变量的总结
关于互斥量std::mutex的总结互斥量用于组成代码的临界区.C++的多线程模型是基于内存的,或者说是基于代码片段的,这和我们操作系统学习的临界区概念基本一致,但是与Golang不同,Golang ...
java多线程互斥锁_浅谈Java多线程互斥锁
为了解决竞争条件带来的问题,我们可以对资源上锁.多个线程共同读写的资源称为共享资源,也叫临界资源.涉及操作临界资源的代码区域称为临界区(Critical Section).同一时刻,只能有一个线程进入 ...
C#多线程时对同一资源加锁实现互斥访问
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.T ...
OS: 读者写者问题(写者优先+LINUX+多线程+互斥量+代码)（转）
一. 引子最近想自己写个简单的 WEB SERVER ,为了先练练手,熟悉下在LINUX系统使用基本的进程.线程.互斥等,就拿以前学过的 OS 问题开开刀啦.记得当年学读者写者问题,尤其是写者优先的 ...
【Linux】多线程--互斥锁
文章目录前言基础概念互斥量mutex 多线程模拟抢票(没加锁情况) 为何多线程访问临界资源是不安全互斥锁相关接口多线程模拟抢票(有加锁) 互斥锁实现的基本原理前言为什么线程需要同步和互斥 ...
临界资源互斥访问内核中的up和down函数
信号量(semaphore)是用于保护临界区的一种常用方法.只有得到信号量的进程才能执行临界区代码,而没有得到信号量的进程进入休眠等待状态. Linux系统中与信号量相关的操作主要有如下4种. 1 定 ...

Bakery Algorithm的c#实现用于多线程互斥访问临界资源

Bakery Algorithm的c#实现用于多线程互斥访问临界资源相关推荐

最新文章

热门文章