俄罗斯贵宾会-俄罗斯贵宾会官网
做最好的网站

C#俄罗斯贵宾会:多线程编程实战1.1创建线程

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
//创建线程
//两组范围为1-10的数字会随机交叉输出,说明PrintNumbers方法同时运行在主线程和另一个线程中
namespace Recipe1
{
class Program
{
static void Main(string[] args)
{
Thread th = new Thread(PrintNumbers);
th.Start();
PrintNumbers();
Console.ReadKey();
}
static void PrintNumbers()
{
Console.WriteLine("Starting");
for (int i = 1; i < 10; i++)
{
Console.WriteLine(i);
}
}
}
}

  }

  3.2.2线程同步

  Console.WriteLine("Main() invokee on thread {0}.", Thread.CurrentThread.ManagedThreadId);

    俄罗斯贵宾会 1

  using System;

  Thread primaryThread = Thread.CurrentThread;

  {

  调用求和方法 Add()的线程ID是: 7.

  threads[i].Name = i.ToString() +"号线程";

  using System;

  Console.WriteLine("线程是否启动? {0}", primaryThread.IsAlive);

  Console.WriteLine("************* 两个线程同时工作 *****************");

  前面提到,线程都是独立的执行单元,可以访问共享的数据。也就是说,在一个拥有多个次线程的程序中,每个线程都可以访问同一个共享的数据。再稍加思考你会发现这样可能会出问题:由于线程调度器会随机的挂起某一个线程(前面介绍的线程间的切换),所以当线程a对共享数据D的访问(修改、删除等操作)完成之前被挂起,而此时线程b又恰好去访问数据D,那么线程b访问的则是一个不稳定的数据。这样就会产生非常难以发现bug,由于是随机发生的,产生的结果是不可预测的,这样样的bug也都很难重现和调试。这就是并发问题。

  Thread primaryThread = Thread.CurrentThread;

  //声明线程变量并赋值为当前线程

  for (int i = 0; i < 10; i++)

 

  Monitor.Exit(this);

  static int Add(int x, int y)

  }

  这里先说一下前台线程与后台线程。前台线程能阻止应用程序的终止,既直到所有前台线程终止后才会彻底关闭应用程序。而对后台线程而言,当所有前台线程终止时,后台线程会被自动终止,不论后台线程是否正在执行任务。默认情况下通过Thread.Start()方法创建的线程都自动为前台线程,把线程的属性IsBackground设为true时就将线程转为后台线程。

  3.1.1异步调用线程

  //为了增加冲突的几率及,使各线程各自等待随机的时长

  Console.WriteLine(""nMain()方法中执行其他任务........"n");

  3.3BackgroundWorker组件

  {

  Console.WriteLine("************** 显示当前线程的相关信息 *************");

  //打印类

  MessageBox.Show(ex.Message);

  进程会包含一个进入此入口的线程,我们称之为主线程。其中,特性 [STAThread] 指示应用程序的默认线程模型是单线程单元(相关信息可参考http://msdn.microsoft.com/en-us/library/system.stathreadattribute(VS.71).aspx.aspx))。只包含一个主线程的进程是线程安全的,相当于程序仅有一条工作线,只有完成了前面的任务才能执行排在后面的任务。

  Console.ReadLine();

  }

  同步后执行结果如下:

  }

  using System.Runtime.Remoting.Messaging;

  }

  {

  private void backgroundWorker1_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)

  }

  int numTwo = int.Parse(this.textBox2.Text);

  //创建一个打印对象实例

  //将委托实例指向Add()方法

  情形一

  {

  Console.Write("{0} ", i);

  //停留5秒,模拟耗时任务

  private void button1_Click(object sender, EventArgs e)

  //将委托实例指向Add()方法

  AddOp pAddOp = new AddOp(Add);

  //开始委托次线程调用。委托BeginInvoke()方法返回的类型是IAsyncResult,

  ******* 线程同步,“阻塞”调用,两个线程工作 *********

  namespace MultiThread

  {

 

  }

  而线程则只是进程中的一个基本执行单元。一个应用程序往往只有一个程序入口,如:

  }

  }

  //判断委托线程是否执行完任务,

  Thread.Sleep(5000);

  this.backgroundWorker1.RunWorkerAsync(args);

  threads[i] = new Thread(new ThreadStart(printer.PrintNumbers));

 

  在.NET平台下,System.Threading命名空间提供了许多类型来构建多线程应用程序,可以说是专为多线程服务的。由于本文仅是想起到一个“抛砖引玉”的作用,所以对于这一块不会探讨过多、过深,主要使用System.Threading.Thread类。

  Main()方法工作中.......

  这里再通过一个例子让大家切实体会一下前面说到的并发问题,然后再介绍线程同步。

  public delegate int AddOp(int x, int y);

  {

  输出结果与上面的一样。

  IAsyncResult iftAR = pAddOp.BeginInvoke(10, 10, null, null);

  //声明指向含两个int型参数、返回值为int型的函数的委托

  Random r = new Random();

 

  }

  }

  AddParams args = (AddParams)e.Argument;

  //打印类

  在介绍线程同步之前,先介绍一个与此紧密相关的概念——并发问题。

  //同时主线程在执行主函数中的其他任务

  Console.WriteLine("线程的优先级: {0}", primaryThread.Priority);

原文:http://blog.sina.com.cn/s/blog_4e61c4290100ndyl.html

  //求和的函数

  本文如果能为刚接触多线程的朋友起到抛砖引玉的作用也就心满意足了。当然,本人才疏学浅,文中难免会有不足或错误的地方,恳请各位朋友多多指点。

  using System.Threading; //引入System.Threading命名空间

  }

  1.理解多线程

  3.2通过委托构建多线程应用程序

  primaryThread.Name = "主线程";

  {

  Console.WriteLine();

  Thread SecondThread = new Thread(new ThreadStart(PrintNumbers));

  public void PrintNumbers()

  Console.WriteLine("10 + 10 = {0}.", answer);

  然当在程序处理一个很耗时的任务,如输出一个大的文件或远程访问数据库等,此时的窗体界面程序对用户而言基本像是没反应一样,菜单、按钮等都用不了。因为窗体上控件的响应事件也是需要主线程来执行的,而主线程正忙着干其他的事,控件响应事件就只能排队等着主线程忙完了再执行。

  {

  //backgroundWorker新生成的线程开始工作

  {

  {

  Console.WriteLine("打印数字: ");

  }

  //显示线程的相关信息

  {

  BackgroundWorker组件位于工具箱中,用于方便的创建线程异步的程序。新建一个WindowsForms应用程序,界面如下:

  {

  3.创建多线程应用程序

  相信到这,应该对多线程有个比较感性的认识了。但笔者在这要提醒一下,基于单核计算机的多线程其实只是操作系统施展的一个障眼法而已(但这不会干扰我们理解构建多线程应用程序的思路),他并不能缩短完成所有任务的时间,有时反而还会因为使用过多的线程而降低性能、延长时间。之所以这样,是因为对于单CPU而言,在一个单位时间(也称时间片)内,只能执行一个线程,即只能干一件事。当一个线程的时间片用完时,系统会将该线程挂起,下一个时间内再执行另一个线程,如此,CPU以时间片为间隔在多个线程之间交替执行运算(其实这里还与每个线程的优先级有关,级别高的会优先处理)。由于交替时间间隔很短,所以造成了各个线程都在“同时”工作的假象;而如果线程数目过多,由于系统挂起线程时要记录线程当前的状态数据等,这样又势必会降低程序的整体性能。但对于这些,多核计算机就能从本质上(真正的同时工作)提高程序的执行效率。

欢迎进入.NET社区论坛,与200万技术人员互动交流 >>进入

  }

  Console.WriteLine("******* 委托异步线程 两个线程“同时”工作 *********");

  }

  线程异步往往是通过创建多个线程执行多个任务,多个工作线同时开工,类似多辆在宽广的公路上并行的汽车同时前进,互不干扰(读者要明白,本质上并没有“同时”,仅仅是操作系统玩的一个障眼法。但这个障眼法却对提高我们的程序与用户之间的交互、以及提高程序的友好性很有用,不是吗)。

 

  Console.WriteLine("********* 并发问题演示 ***************");

  SecondThread.Start();

  {

  }

  //指示调用该方法的线程ID,ManagedThreadId是线程的唯一标示

  b = numb2;

  //返回值

  Console.WriteLine("10 + 25 = {0}", pAddOp(10, 5));

  {

  //打印数字

  3.1.2并发问题

  }

  static void Main(string[] args)

  {

  }

  }

  运行结果如下:

  }

  {

  也可以使用System.Threading命名空间下的Monitor类进行同步,两者内涵是一样的,但Monitor类更灵活,这里就不在做过多的探讨,代码如下:

  using System;

  static void Main()   //应用程序主入口点

  try

  打印数字:

 

  public class Printer

  static void Main(string[] args)

  //获取传入的AddParams对象

  {

  using System;

  下面先看一个例子,该例子创建一个次线程执行打印数字的任务,而主线程则干其他的事,两者同时进行,互不干扰。

  {

  for (int i = 0; i < 10; i++)

  int numOne = int.Parse(this.textBox1.Text);

  Thread.Sleep(2000 * r.Next(5));

  输出结果为:

  namespace MultiThread

  Console.ReadLine();

  Console.WriteLine("-> {0} 正在执行打印任务,开始打印数字:", Thread.CurrentThread.Name);

  //模拟一个过程,停留5秒

  //声明指向含两个int型参数、返回值为int型的函数的委托

  //打印数字

  Console.WriteLine("Main()方法工作中.......");

  Application.EnableVisualStyles();

  //为了增加冲突的几率及,使各线程各自等待随机的时长

  //将每一个线程都指向printer的PrintNumbers()方法

  return sum;

  {

  Main()方法工作中.......

  Thread.Sleep(2000);

  {

  }

  primaryThread.Name = "主线程";

  using System.Threading;

  IAsyncResult iftAR = pAddOp.BeginInvoke(10, 10, null, null);

  //显示主线程的唯一标示

  for (int i = 0; i < 10; i++)

  //定义一个指向包含两个int型参数、返回值为int型的函数的委托

  为了解决多线程共同访问一个共享资源(也称互斥访问)时产生的并发问题,线程同步就应运而生了。线程同步的机理,简单的说,就是防止多个线程同时访问某个共享的资源。做法很简单,标记访问某共享资源的那部分代码,当程序运行到有标记的地方时,CLR(具体是什么可以先不管,只要知道它能控制就行)对各线程进行调整:如果已有线程在访问一资源,CLR就会将其他访问这一资源的线程挂起,直到前一线程结束对该资源的访问。这样就保证了同一时间只有一个线程访问该资源。打个比方,就如某资源放在只有一独木桥相连的孤岛上,如果要使用该资源,大家就得排队,一个一个来,前面的回来了,下一个再去,前面的没回来,后面的就原地待命。

  class Class

  Application.SetCompatibleTextRenderingDefault(false);

  //创建一个指向Add()方法的AddOp对象p

  Random r = new Random();

  {

 

  return sum;

  这里只是把基本的概念及原理做了一个简单的阐述,不至于看后面的程序时糊里糊涂的。具体如何编写代码,下面的段落将做详细介绍。

  using System.Windows.Forms;

  using System.Threading;

  using System.Threading;

  }

  int sum = x + y;

  随着双核、四核等多核处理器的推广,多核处理器或超线程单核处理器的计算机已很常见,基于多核处理的编程技术也开始受到程序员们普遍关注。这其中一个重要的方面就是构建多线程应用程序(因为不使用多线程的话,开发人员就不能充分发挥多核计算机的强大性能)。

  int answer = pAddOp.EndInvoke(iftAR);

  输出结果如下:

  线程的优先级: Normal

  }

  Thread.Sleep(2000 * r.Next(5));

  class Class

  Console.WriteLine("调用Main()的主线程的线程ID是:{0}.", Thread.CurrentThread.ManagedThreadId);

  }

  }

  }

  10 + 10 = 20.

  3.1通过System.Threading命名空间的类构建

  为了克服单线程的这个缺陷,Win32 API可以让主线程再创建其他的次线程,但不论是主线程还是次线程都是进程中独立的执行单元,可以同时访问共享的数据,这样就有了多线程这个概念。

  2. 线程异步与线程同步

  //打印类

  //指示调用该方法的线程ID,ManagedThreadId是线程的唯一标示

  Console.WriteLine("-> {0} 在执行主函数 Main()。", Thread.CurrentThread.Name);

  //参数类,这个类仅仅起到一个记录并传递参数的作用

  Console.ReadLine();

 

本文由俄罗斯贵宾会发布于编程,转载请注明出处:C#俄罗斯贵宾会:多线程编程实战1.1创建线程

您可能还会对下面的文章感兴趣: