第三节:ThreadPool的线程开启、线程等待、线程池的设置、定时功能

一. ThreadPool简介

  ThreadPool简介:ThreadPool是一个线程池,当你需要开启n个线程时候,只需把这个指令抛给线程池,它将自动分配线程进行处理,它诞生于.Net 2.0时代。

  ThreadPool与Thread的区别:

    ①:Thread每开启一个异步任务,就需要使用一个Thread,具有专一性,即使Thread已经死掉,仍然需要占用资源。

    ②:ThreadPool能实现n个线程处理n+m个异步任务,且没有死线程,默认都是初始化的。

二. 深究ThreadPool类

1:QueueUserWorkItem方法,将方法排入队列以便开启异步线程,它有两个重载。

  a:QueueUserWorkItem(WaitCallback callBack),WaitCallback是一个有一个object类型参数且无返回值的委托

  b:QueueUserWorkItem(WaitCallback callBack, object state),WaitCallback是一个有一个object类型参数且无返回值的委托,state即WaitCallback中需要的参数, 不推荐这么使用,存在拆箱装箱的转换问题,影响性能。

使用方式:

  a:严格的卡定义的写法,第一个重载和第二个重载均是处理有一个参数的函数,大于一个参数需要封装一个实体类,所需参数在实体类的构造函数中引入,然后调用第一个重载即可.

   (不推荐这种写法)

通用写法 (可以处理任何参数个数的方法),这里不使用n即可。

ThreadPool.QueueUserWorkItem((n) =>

{

  TestThread2(i.ToString(),i.ToString());

});

通用写法的简化版:

ThreadPool.QueueUserWorkItem(n => TestThread2(i.ToString(), i.ToString()));

代码如下:

第三节:ThreadPool的线程开启、线程等待、线程池的设置、定时功能

2:线程等待(有局限性的)

  利用ManualResetEvent类和WaitOne方法,多个线程的话需要写for循环。

第三节:ThreadPool的线程开启、线程等待、线程池的设置、定时功能

运行结果:

第三节:ThreadPool的线程开启、线程等待、线程池的设置、定时功能

3:常用方法

  a:设置工作线程和IO线程的最大和最小值,SetMaxThreads和SetMinThreads。

  b:获取工作线程和IO线程最大、最小、可用值,GetMaxThreads、GetMinThreads、GetAvailableThreads。

第三节:ThreadPool的线程开启、线程等待、线程池的设置、定时功能

测试结果:

第三节:ThreadPool的线程开启、线程等待、线程池的设置、定时功能

第三节:ThreadPool的线程开启、线程等待、线程池的设置、定时功能

三. 扩展一个定时器功能

1:RegisterWaitForSingleObject类,但是不常用.(涉及到定时任务,建议使用Quartz.Net)

2:System.threading命名空间下的Thread类,通过查看源码,构造函数中有四个参数,第一个是object参数的委托,第二个是委托需要的值,

  第三个是调用 callback 之前延迟的时间量(以毫秒为单位)

  第四个是 调用 callback 的时间间隔(以毫秒为单位)

   private void button12_Click(object sender, EventArgs e)
{
Stopwatch watch = new Stopwatch();
watch.Start();
Console.WriteLine("----------------- button_Click 开始 主线程id为:{0} --------------------------", Thread.CurrentThread.ManagedThreadId); #region 01-RegisterWaitForSingleObject
//{
// //每隔3s开启一个线程执行业务逻辑
// ThreadPool.RegisterWaitForSingleObject(new AutoResetEvent(true), new WaitOrTimerCallback((obj, b) =>
// {
// //做逻辑判断,编写业务逻辑
// Console.WriteLine("obj={0},tid={1}, datetime={2}", obj, Thread.CurrentThread.ManagedThreadId, DateTime.Now); // }), "hello world", 3000, false);
//}
#endregion #region 02-Timer类
{
//2秒后开启该线程,然后每隔4s调用一次
System.Threading.Timer timer = new System.Threading.Timer((n) =>
{
//书写业务逻辑
Console.WriteLine("我是子线程中的业务逻辑哦");
}, "", , );
}
#endregion watch.Stop();
Console.WriteLine("----------------- button_Click 结束 主线程id为:{0} 总耗时:{1}--------------------------", Thread.CurrentThread.ManagedThreadId, watch.ElapsedMilliseconds); }

第三节:ThreadPool的线程开启、线程等待、线程池的设置、定时功能

上一篇:MyEclipse8.5 中安装Spket插件


下一篇:ubuntu 安装ftp,配置,和java调用