C#多线程经典示例（吃苹果）
本文主要讲述了多线程开发中经典示例，通过本示例，可以加深对多线程的理解。
示例概述：
下面用一个模拟吃苹果的实例，说明C#中多线程的实现方法。要求开发一个程序实现如下情况：一个家庭有三个孩子，爸爸妈妈不断削苹果往盘子里面放，老大、老二、老三不断从盘子里面取苹果吃。盘子的大小有限，最多只能放5个苹果，并且爸妈不能同时往盘子里面放苹果，妈妈具有优先权。三个孩子取苹果时，盘子不能为空，三人不能同时取，老三优先权最高，老大最低。老大吃的最快，取的频率最高，老二次之。
涉及到知识点：
- 线程Thread 创建并控制线程，设置其优先级并获取其状态。
- 锁 lock 用于实现多线程同步的最直接办法就是加锁，它可以把一段代码定义为互斥段，在一个时刻内只允许一个线程进入执行，而其他线程必须等待。
- 事件EventHandler 声明一个事件，用于通知界面做改变
设计思路：
- Productor 表示生产者，用于削苹果。
- Consumer 表示消费者，用于吃苹果。
- Dish 盘子，用于装苹果，做为中间类
- EatAppleSmp 的BeginEat()方法，表示开始吃苹果，启动线程
效果图如下【爸爸妈妈削苹果，孩子吃苹果】：
后台输出如下：
Mama放1个苹果 Baba放1个苹果 Dage取苹果吃... Erdi取苹果吃... Sandi等待取苹果 Mama放1个苹果 Sandi取苹果吃... Baba放1个苹果 Dage取苹果吃... Mama放1个苹果 Baba放1个苹果 Erdi取苹果吃... Mama放1个苹果 Baba放1个苹果 Dage取苹果吃... Sandi取苹果吃... Mama放1个苹果 Baba放1个苹果 Erdi取苹果吃... Mama放1个苹果 Baba放1个苹果 Dage取苹果吃... Mama放1个苹果 Baba放1个苹果 Sandi取苹果吃... Mama放1个苹果 Baba正在等待放入苹果 Erdi取苹果吃... Baba放1个苹果 Dage取苹果吃... Mama放1个苹果 Baba正在等待放入苹果 Mama正在等待放入苹果 Sandi取苹果吃... Baba放1个苹果 Mama正在等待放入苹果 Erdi取苹果吃... Mama放1个苹果 Dage取苹果吃... Baba放1个苹果 Mama正在等待放入苹果 Dage取苹果吃... Mama放1个苹果 Baba正在等待放入苹果 Erdi取苹果吃... Baba放1个苹果 Sandi取苹果吃... Mama放1个苹果 Baba正在等待放入苹果 Dage取苹果吃... Baba放1个苹果 Mama正在等待放入苹果 Erdi取苹果吃... Mama放1个苹果 Baba正在等待放入苹果 Sandi取苹果吃... Baba放1个苹果 Mama正在等待放入苹果 Dage取苹果吃... Mama放1个苹果 Baba正在等待放入苹果 Mama正在等待放入苹果 Erdi取苹果吃... Mama放1个苹果 Baba正在等待放入苹果 Dage取苹果吃... Baba放1个苹果 Mama正在等待放入苹果 Sandi取苹果吃... Mama放1个苹果 Baba正在等待放入苹果 Mama正在等待放入苹果 线程 'Mama' (0x1ce0) 已退出，返回值为 0 (0x0)。 线程 'Baba' (0x1888) 已退出，返回值为 0 (0x0)。 Erdi取苹果吃... Dage取苹果吃... Sandi取苹果吃... Dage取苹果吃... Erdi取苹果吃... Dage等待取苹果 Sandi等待取苹果 Erdi等待取苹果 后台输出
Productor 代码如下：
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
namespace DemoSharp.EatApple
{
/// <summary>
/// 生产者
/// </summary>
public class Productor
{
private Dish dish;
private string name;
public string Name
{
get { return name; }
set { name = value; }
}
public EventHandler PutAction;//声明一个事件，当放苹果时触发该事件
public Productor(string name, Dish dish)
{
this.name = name;
this.dish = dish;
}
public void run()
{
while (true)
{
bool flag= dish.Put(name);
if (flag)
{
if (PutAction != null)
{
PutAction(this, null);
}
try
{
Thread.Sleep(600);//削苹果时间
}
catch (Exception ex)
{
}
}
else {
break;
}
}
}
}
}
Consumer代码如下：
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
namespace DemoSharp.EatApple
{
/// <summary>
/// 消费者
/// </summary>
public class Consumer
{
private string name;
public string Name
{
get { return name; }
set { name = value; }
}
private Dish dish;
private int timelong;
public EventHandler GetAction;//声明一个事件，当放苹果时触发该事件
public Consumer(string name, Dish dish, int timelong)
{
this.name = name;
this.dish = dish;
this.timelong = timelong;
}
public void run()
{
while (true)
{
bool flag= dish.Get(name);
if (flag)
{
//如果取到苹果，则调用事件，并开始吃
if (GetAction != null)
{
GetAction(this, null);
}
try
{
Thread.Sleep(timelong);//吃苹果时间
}
catch (ThreadInterruptedException)
{
}
}
else {
break;
}
}
}
}
}
Dish代码如下：
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
namespace DemoSharp.EatApple
{
/// <summary>
/// 盘子，属于中间类
/// </summary>
public class Dish
{
private int f = 5;//表示盘子中还可以放几个苹果，最多只能放5个苹果
private int EnabledNum;//可放苹果总数
private int n = 0; //表示已经放了多少个苹果
private object objGet = new object();
private object objPut = new object();
/// <summary>
/// 构造函数，初始化Dish对象
/// </summary>
/// <param name="num">表示削够多少个苹果结束</param>
public Dish(int num)
{
this.EnabledNum = num;
}
/// <summary>
/// 放苹果的方法
/// </summary>
/// <param name="name"></param>
///<returns>是否放成功</returns>
public bool Put(string name)
{
lock (this)//同步控制放苹果
{
bool flag = false;
while (f == 0)//苹果已满，线程等待
{
try
{
System.Console.WriteLine(name + "正在等待放入苹果");
Monitor.Wait(this);
}
catch (Exception ex)
{
System.Console.WriteLine(name + "等不及了");
}
}
if (n < EnabledNum)
{
f = f - 1;//削完一个苹果放一次
n = n + 1;
System.Console.WriteLine(name + "放1个苹果");
flag = true;
}
Monitor.PulseAll(this);
return flag;
}
}
/// <summary>
/// 取苹果的方法
/// </summary>
/// <param name="name"></param>
public bool Get(string name)
{
lock (this)//同步控制取苹果
{
bool flag = false;
while (f == 5)
{
try
{
System.Console.WriteLine(name + "等待取苹果");
Monitor.Wait(this);
}
catch (ThreadInterruptedException) { }
}
if (n <= EnabledNum)
{
f = f + 1;
System.Console.WriteLine(name + "取苹果吃...");
flag = true;
}
Monitor.PulseAll(this);
return flag;
}
}
}
}
EatAppleSmp代码如下：
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
namespace DemoSharp.EatApple
{
public class EatAppleSmp
{
public EventHandler PutAction;//声明一个事件，当放苹果时触发该事件
public EventHandler GetAction;//声明一个事件，当放苹果时触发该事件
/// <summary>
/// 开始吃苹果
/// </summary>
public void BeginEat()
{
Thread th_mother, th_father, th_young, th_middle, th_old;//依次表示妈妈，爸爸，小弟，二弟，大哥
Dish dish = new Dish(30);
Productor mother = new Productor("Mama", dish);//建立线程
mother.PutAction += PutActionMethod;
Productor father = new Productor("Baba", dish);
father.PutAction += PutActionMethod;
Consumer old = new Consumer("Dage", dish, 1200);
old.GetAction += GetActionMethod;
Consumer middle = new Consumer("Erdi", dish, 1500);
middle.GetAction += GetActionMethod;
Consumer young = new Consumer("Sandi", dish, 1800);
young.GetAction += GetActionMethod;
th_mother = new Thread(new ThreadStart(mother.run));
th_mother.Name = "Mama";
th_father = new Thread(new ThreadStart(father.run));
th_father.Name = "Baba";
th_old = new Thread(new ThreadStart(old.run));
th_old.Name = "Dage";
th_middle = new Thread(new ThreadStart(middle.run));
th_middle.Name = "Erdi";
th_young = new Thread(new ThreadStart(young.run));
th_young.Name = "Sandi";
th_mother.Priority = ThreadPriority.Highest;//设置优先级
th_father.Priority = ThreadPriority.Normal;
th_old.Priority = ThreadPriority.Lowest;
th_middle.Priority = ThreadPriority.Normal;
th_young.Priority = ThreadPriority.Highest;
th_mother.Start();
th_father.Start();
th_old.Start();
th_middle.Start();
th_young.Start();
}
private void GetActionMethod(object sender,EventArgs e)
{
if (GetAction != null)
{
GetAction(sender, e);
}
}
private void PutActionMethod(object sender, EventArgs e)
{
if (PutAction != null)
{
PutAction(sender, e);
}
}
}
}
界面类代码如下：
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using DemoSharp.EatApple;
namespace DemoSharp
{
/// <summary>
/// 页面类
/// </summary>
public partial class EatAppleForm : Form
{
private EatAppleSmp m_EatAppleSmp = new EatAppleSmp();
public EatAppleForm()
{
InitializeComponent();
InitView();
m_EatAppleSmp.PutAction += PutActionMethod;
m_EatAppleSmp.GetAction += GetActionMethod;
}
/// <summary>
/// 初始化GroupBox
/// </summary>
private void InitView()
{
this.gbBaba.Controls.Clear();
this.gbMama.Controls.Clear();
this.gbDage.Controls.Clear();
this.gbErdi.Controls.Clear();
this.gbSandi.Controls.Clear();
}
/// <summary>
/// 启动线程
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void btnStart_Click(object sender, EventArgs e)
{
this.m_EatAppleSmp.BeginEat();
}
/// <summary>
/// 放苹果事件
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void PutActionMethod(object sender, EventArgs e)
{
Productor p = sender as Productor;
if (p != null)
{
if (p.Name == "Baba")
{
AddItemToGroupBox(this.gbBaba, this.lblBaba);
}
if (p.Name == "Mama")
{
AddItemToGroupBox(this.gbMama, this.lblMama);
}
}
}
/// <summary>
/// 吃苹果事件
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
public void GetActionMethod(object sender, EventArgs e)
{
Consumer c = sender as Consumer;
if (c != null)
{
if (c.Name == "Dage")
{
AddItemToGroupBox(this.gbDage, this.lblDage);
}
if (c.Name == "Erdi")
{
AddItemToGroupBox(this.gbErdi, this.lblErdi);
}
if (c.Name == "Sandi")
{
AddItemToGroupBox(this.gbSandi, this.lblSandi);
}
}
}
/// <summary>
/// 往指定的GroupBox中添加对象
/// </summary>
/// <param name="gbView"></param>
/// <param name="lbl"></param>
private void AddItemToGroupBox(GroupBox gbView,Label lbl)
{
gbView.Invoke(new Action(() =>
{
PictureBox p = new PictureBox();
p.Width = 20;
p.Height = 20;
p.Dock = DockStyle.Left;
p.Image = this.imgLst01.Images[0];
p.Margin = new Padding(2);
gbView.Controls.Add(p);
}));
//显示个数
lbl.Invoke(new Action(() => {
if (string.IsNullOrEmpty(lbl.Text))
{
lbl.Text = "0";
}
lbl.Text = (int.Parse(lbl.Text) + 1).ToString();
}));
}
}
}
以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，同时也希望多多支持我们！
相关推荐
-
C#在Unity游戏开发中进行多线程编程的方法
在这之前,有很多人在质疑Unity支不支持多线程,事实上Unity是支持多线程的.而提到多线程就要提到Unity非常常用的协程,然而协程并非真正的多线程.协程其实是等某个操作完成之后再执行后面的代码,或者说是控制代码在特定的时机执行.而多线程在Unity渲染和复杂逻辑运算时可以高效的使用多核CPU,帮助程序可以更高效的运行.本篇主要介绍在Unity中如何使用多线程. 首先引入C#中使用多线程的类库 using System.Threading; 创建线程实例的四种方式 一.线程执行无参方法 构造
-
C#实现多线程下载文件的方法
本文实例讲述了C#实现多线程下载文件的方法.分享给大家供大家参考.具体实现方法如下: using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.IO; using System.Threading; using System.Net; namespace WfpApp { public class MultiDownload { #region 变量 pri
-
C#实现多线程写入同一个文件的方法
本文实例讲述了C#实现多线程写入同一个文件的方法.分享给大家供大家参考.具体实现方法如下: namespace WfpApp { public partial class Form2 : Form { object obj = new object(); public Form2() { InitializeComponent(); System.Threading.Thread thread; string[] users = new string[] { "zkk", "
-
C#队列Queue多线程用法实例
本文实例讲述了C#队列Queue多线程用法.分享给大家供大家参考.具体分析如下: 这里展示一个例子,供学习使用: private void button_测试Queue结合多线程_Click(object sender, EventArgs e) { Console.WriteLine("初始化队列"); queue = new Queue<string>(); string[] cars = new string[]{"宝马","奔驰&quo
-
解析C#多线程编程中异步多线程的实现及线程池的使用
0.线程的本质 线程不是一个计算机硬件的功能,而是操作系统提供的一种逻辑功能,线程本质上是进程中一段并发运行的代码,所以线程需要操作系统投入CPU资源来运行和调度. 1.多线程: 使用多个处理句柄同时对多个任务进行控制处理的一种技术.据博主的理解,多线程就是该应用的主线程任命其他多个线程去协助它完成需要的功能,并且主线程和协助线程是完全独立进行的.不知道这样说好不好理解,后面慢慢在使用中会有更加详细的讲解. 2.多线程的使用: (1)最简单.最原始的使用方法:Thread oGetArgThre
-
C#多线程编程详解
C#提供了丰富的多线程操作,为编程带来了极大的便利. 一.使用线程的理由 1.可以使用线程将代码同其他代码隔离,提高应用程序的可靠性. 2.可以使用线程来简化编码. 3.可以使用线程来实现并发执行. 二.基本知识 1.进程与线程:进程作为操作系统执行程序的基本单位,拥有应用程序的资源,进程包含线程,进程的资源被线程共享,线程不拥有资源. 2.前台线程和后台线程:通过Thread类新建线程默认为前台线程.当所有前台线程关闭时,所有的后台线程也会被直接终止,不会抛出异常. 3.挂起(Suspend)
-
C#基于委托实现多线程之间操作的方法
本文实例讲述了C#基于委托实现多线程之间操作的方法.分享给大家供大家参考,具体如下: 有的时候我们要起多个线程,更多的时候可能会有某个线程会去操作其他线程里的属性. 但是线程是并发的,一般的调用是无法实现我们的要求的. 于是,我们在这里就可以用委托,代码如下 private delegate void DelegateInfo(); private delegate void DelegateIsEnd(); //这个是线程调用其他线程的方法 private void Dowork() { //
-
C#如何对多线程、多任务管理（demo）
下面一段内容有项目需求有项目分析,通过一个小demo给大家展示下C#如何对多线程.多任务管理的. 项目需求:假设多个任务需要执行,每个任务不是一时半会能完成(需要能看到中间执行状况): 多个任务 根据条件不同 可能需要不同的处理 项目分析: 多线程并发执行多任务: 对任务进行管理,追踪中间执行状态: 运用策略模式抽象执行类: public enum TaskStatus { wait = 0, working = 1, stop = 2, suspend = 3, complete = 4, f
-
C#多线程处理多个队列数据的方法
本文实例讲述了C#多线程处理多个队列数据的方法.分享给大家供大家参考.具体实现方法如下: using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Collections; using System.Windows.Forms; namespace ThredProcessQueue { //用于顯示狀態的代理
-
C#使用读写锁三行代码简单解决多线程并发的问题
在开发程序的过程中,难免少不了写入错误日志这个关键功能.实现这个功能,可以选择使用第三方日志插件,也可以选择使用数据库,还可以自己写个简单的方法把错误信息记录到日志文件. 选择最后一种方法实现的时候,若对文件操作与线程同步不熟悉,问题就有可能出现了,因为同一个文件并不允许多个线程同时写入,否则会提示"文件正在由另一进程使用,因此该进程无法访问此文件". 这是文件的并发写入问题,就需要用到线程同步.而微软也给线程同步提供了一些相关的类可以达到这样的目的,本文使用到的 System.Thr