首页/电脑学习/内容

怎么创建与打开线程_C#线程的打开交互处理示例图文说明教程详细说明

电脑学习2023-06-22 阅读()
[摘要]如何创建和启动线程_C#线程的启动交互处理示例教程详解 开发碰到很棘手的问题, 寻找解决方法. 品味程序出错过程, 逐步跟踪程序执行过程, 每一行代码每一条语句全部执行, 线程处理的优点是可以创建使...

如何创建和启动线程_C#线程的启动交互处理示例教程详解

开发碰到很棘手的问题, 寻找解决方法. 品味程序出错过程, 逐步跟踪程序执行过程, 每一行代码每一条语句全部执行, 线程处理的优点是可以创建使用多个执行线程的应用程序。例如,某一可以具有管理与用户交互的用户界面线程,以及在用户界面线程等待。

本示例讲解如何创建和启动线程,并显示了同时在同一进程内运行的两个线程间的交互。请注意,不必停止或释放线程。这由公共语言运行库自动完成。

程序从创建Alpha类型的对象和引用Alpha类的Beta方法的线程开始。然后启动该线程。线程的IsAlive属性允许程序等待,直到线程被初始化(被创建、被分配等)为止。

主线程通过Thread访问,而Sleep方法通知线程放弃其时间片并在一定毫秒数期间停止执行。然后oThread被停止和联接。联接一个线程将使主线程等待它死亡或等待它在指定的时间后过期。最后,程序尝试重新启动oThread,但由于线程无法在停止(中止)后重新启动而告失败。有关临时停止执行的,请参见挂起线程执行。

//StopJoin.csusingSystem;usingSystem.Threading;publicclassAlpha}};publicclassSimplecatchreturn0;}}输出示例ThreadStart/Stop/JoinSampleAlpha.Betaisrunninginitsownthread.Alpha.Betaisrunninginitsownthread.Alpha.Betaisrunninginitsownthread.......Alpha.BetahasfinishedTrytorestarttheAlpha.BetathreadThreadStateExceptiontryingtorestartAlpha.Beta.Expectedsinceabortedthreadscannotberestarted.示例2:同步两个线程:制造者和使用者

下面的示例显示如何使用C#lock关键字和Monitor对象的Pulse方法完成同步。Pulse方法通知等待队列中的线程对象的状态已更改。(有关脉冲的更多详细,请参见Monitor.Pulse方法)。

本示例创建一个Cell对象,它具有两个方法:ReadFromCell和WriteToCell。从CellProd和CellCons类创建另外两个对象;这两个对象均具有调用ReadFromCell和WriteToCell的ThreadRun方法。通过等待依次到达的来自Monitor对象的“脉冲”即可完成同步。也就是说,首先产生一个项(此时使用者等待脉冲),然后发生一个脉冲,接着使用者使用所产生的项(此时制造者等待脉冲),依此类推。

//MonitorSample.cs//ThisexampleshowsuseofthefollowingmethodsoftheC#lockkeyword//andtheMonitorclass//inthreads://Monitor.Pulse//Monitor.WaitusingSystem;usingSystem.Threading;publicclassMonitorSamplecatchcatch//EventhoughMainreturnsvoid,thisprovidesareturncodeto//theparentprocess.Environment.ExitCode=result;}}publicclassCellProdpublicvoidThreadRun}publicclassCellConspublicvoidThreadRun}publicclassCellcatchcatch}Console.WriteLine;readerFlag=false;//Resetthestateflagtosayconsuming//isdone.Monitor.Pulse;//PulsetellsCell.WriteToCellthat//Cell.ReadFromCellisdone.}//ExitsynchronizationblockreturncellContents;}publicvoidWriteToCellcatchcatch}cellContents=n;Console.WriteLine;readerFlag=true;//Resetthestateflagtosayproducing//isdoneMonitor.Pulse;//PulsetellsCell.ReadFromCellthat//Cell.WriteToCellisdone.}//Exitsynchronizationblock}}输出示例Produce:1Consume:1Produce:2Consume:2Produce:3Consume:3......Produce:20Consume:20

[page]
 

在.net中为我们提供了两种启动线程的方式,一种是不带参数的启动方式,另一种是带参数的启动的方式。

1:不带参数的启动方式,可以使用ThreadStart来实例化Thread,ThreadStart是在.Net Framework 中已经定义好的委托,ThreadStart定义为:

public delegate void ThreadStart();

使用方法如下面的代码:

static void Main(string[] args)
{
Demo demo = new Demo();

Thread t = new Thread(new ThreadStart(demo.Run));
t.Name = "NoParameterThread";
t.Start();
}

public class Demo
{
int interval = 1000;
///


/// 不带参数的启动方法
///

public void Run()
{
for (int i = 0; i < 10; i++)
{
DoSomething();
}
}

private void DoSomething()
{
Console.WriteLine(string.Format("当前线程:{0},当前系统时间为:{1}", Thread.CurrentThread.Name, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")));
Thread.Sleep(interval);
}
}

 

2:带参数的启动方法,就要使用ParameterizedThreadStart委托来实例化Thread了,和ThreadStart一样的是它也是线程启动时要执行的方法,和ThreadStart不同的是,它在实例化时可以用一个带有一个Object参数的方法作为构造函数的参数,而实例化ThreadStart时所用到的方法是没有参数的。ParameterizedThreadStart定义为:

public delegate void ParameterizedThreadStart(object obj);

使用方法如下面的代码:

public class Demo
{
int interval = 1000;

private void DoSomething()
{
Console.WriteLine(string.Format("当前线程:{0},当前系统时间为:{1}", Thread.CurrentThread.Name, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")));
Thread.Sleep(interval);
}

///


/// 带参数的启动方法
///

///
public void Run(object param)
{
if (param == null)
return;

int.TryParse(param.ToString(), out interval);
for (int i = 0; i < 10; i++)
{
DoSomething();
}
}

}

 

static void Main(string[] args)
{
Demo demo = new Demo();

Thread parameterThread = new Thread(new ParameterizedThreadStart(demo.Run));
parameterThread.Name = "ParameterThread";
parameterThread.Start(2000);
}

3:在很多时候,我们遇到的情况是要传递多个参数,注意到ParameterizedThreadStart委托的参数类型是一个Object对象,为什么是Object这样的参数呢?很简单,因为在.net中Object是所有类型的基类。这样我们可以声明一个类,为这个类增加属性,这些属性也就是参数。

使用方法如下面的代码:

static void Main(string[] args)
{
Demo demo = new Demo();

ThreadParamter p = new ThreadParamter(2000,100);
Thread multiParameterThread = new Thread(new ParameterizedThreadStart(demo.CustomerParamterRun));
multiParameterThread.Name = "MultiParameterThread";
multiParameterThread.Start(p);
}

public class Demo
{
///


/// 带多个参数的启动方法
///

///
public void CustomerParamterRun(object param)
{
if (param == null)
return;

ThreadParamter p = param as ThreadParamter;
if (p != null)
{
for (int i = 0; i < p.LoopCount; i++)
{
Console.WriteLine(string.Format("当前线程:{0},当前系统时间为:{1}", Thread.CurrentThread.Name, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")));
Thread.Sleep(p.Interval);
}
}
}
}

public class ThreadParamter
{
public int Interval { get; set; }
public int LoopCount { get; set; }

public ThreadParamter()
{ }

public ThreadParamter(int interval, int loopCount)
{
this.Interval = interval;
this.LoopCount = loopCount;
}
}

 

4:在遇到业务非常复杂的时候,上面写法还是有问题,封装不够好,我们可以使用装饰模式,对上面的代码进行改进。这样业务发生改变的时候,我们只需要修改核心的实现部分,调用的方法可以不用做任何修改,而且调用方法的代码非常简洁。

修改后的代码如下:

 static void Main(string[] args)
        {
            DecoratorThread t = new DecoratorThread(new ThreadParamter(2000, 100));
            t.Start();
        }

public class ThreadParamter
{
public int Interval { get; set; }
public int LoopCount { get; set; }

public ThreadParamter()
{ }

public ThreadParamter(int interval, int loopCount)
{
this.Interval = interval;
this.LoopCount = loopCount;
}
}

///


/// 使用装饰模式来实现多个参数的
///

public class DecoratorThread
{
private ThreadParamter threadParamter;
private Thread thread;


public DecoratorThread(ThreadParamter threadParamter)
{
this.threadParamter = threadParamter;
thread = new Thread(new ThreadStart(Run));
thread.Name = "DecoratorThread";
}

public void Start()
{
if (thread != null)
{
thread.Start();
}
}

private void Run()
{
for (int i = 0; i < threadParamter.LoopCount; i++)
{
Console.WriteLine(string.Format("当前线程:{0},当前系统时间为:{1}", Thread.CurrentThread.Name, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")));
Thread.Sleep(threadParamter.Interval);
}
}
}

 


学习教程快速掌握从入门到精通的电脑知识



……

相关阅读