多线程实现Thread.Start()与ThreadPool.QueueUserWorkItem两种方式对比

摘要:
线程.睡眠(900000);}DoSomethingThread。Start()方法实现workThreads=newThread[NUMBER_OF_THREADS];workThreads[i]=新线程(st);i++){Thread.Sleep(2000);workThreads[i].Start();

Thread.Start(),ThreadPool.QueueUserWorkItem都是在实现多线程并行编程时常用的方法。两种方式有何异同点,而又该如何取舍?

写一个Demo,分别用两种方式实现。观察各自的现象。 

一个WorkMan class,其内的method doSomething()是每次异步线程调用的方法。该方法只是随机的让线程休眠一段时间。

public void doSomething()
{
     OnBegin(new EventArgs());

     // someone does something here
     var r = new Random();
     int sleepTime = r.Next(3000, 180000);
     Thread.Sleep(900000);

    OnCompleted(new EventArgs());
}

doSomething

Thread.Start()方式实现

workThreads = new Thread[NUMBER_OF_THREADS];

for (var i = 0; i < NUMBER_OF_THREADS; i++)
{
    arrWorkMen[i] = new WorkMan() { 
        WorkStarted = true,
        InstanceID = startThreadNumber
    };

    arrWorkMen[i].BeginHandler += HandleTaskBegin;
    arrWorkMen[i].CompletedHandler += HandleTaskCompleted;

    // create a thread and attach to the object
    var st = new ThreadStart(arrWorkMen[i].doSomething);
    workThreads[i] = new Thread(st);

    startThreadNumber++;
}

for (var i = 0; i < NUMBER_OF_THREADS; i++)
{
    Thread.Sleep(2000);
    workThreads[i].Start();
}                

Thread.Start()

ThreadPool.QueueUserWorkItem方式实现

for (var i = 0; i < NUMBER_OF_THREADS; i++)
{
    arrWorkMen[i] = new WorkMan()
    {
        WorkStarted = true,
        InstanceID = startThreadNumber
    };

    arrWorkMen[i].BeginHandler += HandleTaskBegin;
    arrWorkMen[i].CompletedHandler += HandleTaskCompleted;

    startThreadNumber++;
}

for (var i = 0; i < NUMBER_OF_THREADS; i++)
{
    Thread.Sleep(2000);
     ThreadPool.QueueUserWorkItem(o => arrWorkMen[i].doSomething());
}        

ThreadPool.QueueUserWorkItem

观察两种方式下,线程创建和回收的情况。

同样的场景,每2秒钟发起一新的线程,且每一线程均休眠2分钟。Thread.Start()实现下,线程一路最高飙升到71个,然后随着2分钟后休眠线程的结束,线程个数始终在70、71之间徘徊。而ThreadPool.QueueUserWorkItem的实现下,线程个数到达最高73后,始终在72、73之间徘徊。

多线程实现Thread.Start()与ThreadPool.QueueUserWorkItem两种方式对比第1张

总体来说,做同样的事情。ThreadPool方式产生的线程数略高于Thread.Start()。Thread.Start()产生的线程在完成任务后,很快被系统所回收。而ThreadPool(线程池)方式下,线程在完成工作后会被保留一段时间以备resue。所以,当需求需要大量线程并发工作的时候,不建议使用ThreadPool方式,因为它会保持很多额外的线程。

此处摘录一段来自网络的参考:

As for the ThreadPool, it is designed to use as few threads as possible while also keeping the CPU busy. Ideally, the number of busy threads is equal to the number of CPU cores. However, if the pool detects that its threads are currently not using the CPU (sleeping, or waiting for another thread), it starts up more threads (at a rate of 1/second, up to some maximum) to keep the CPU busy.

 Demo源码:MultipleThreadsWayDemo

免责声明:文章转载自《多线程实现Thread.Start()与ThreadPool.QueueUserWorkItem两种方式对比》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇Chrome 快捷键使用opencv 仿射变换 投射变换, 单应性矩阵下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

Jdk1.8 JUC源码解析(1)-atomic-AtomicXXX

目录     一、Unsafe简介 在正式的开讲 juc-atomic框架系列之前,有必要先来了解下Java中的Unsafe类。 Unsafe类,来源于sun.misc包。该类封装了许多类似指针操作,可以直接进行内存管理、操纵对象、阻塞/唤醒线程等操作。Java本身不直接支持指针的操作,所以这也是该类命名为Unsafe的原因之一。 J.U.C中的许多CA...

阻塞队列和死锁

BlockingQueue        BlockingQueue是并发容器的一种,在J.U.C的包路径下,是线程安全的一种实现,是基于阻塞队列的,该接口提供了相对于Queue的新的put()和take()操作。put()添加元素时,当阻塞队列满的情况下会阻塞下来,当有空间时才能进行添加操作,添加到队列尾部;take()删除元素时,当队列为空时,也会阻塞...

流式处理框架storm浅析(上篇)

本文来自网易云社区 作者:汪建伟 前言 前一段时间参与哨兵流式监控功能设计,调研了两个可以做流式计算的框架:storm和spark streaming,我负责storm的调研工作。断断续续花了一周的时间看了官网上的doc和网络上的一些资料。我把所学到的总结成一个文档,发出来给对storm感兴趣的同事做入门引导。 storm背景 随着互联网的更进一步发...

YUV和RGB格式单像素所占内存大小分析

图片的大小定 义为:w * h,宽高分别为w和h 一、YUV格式 1.1.YUV420格式存储方式:先Y,后V,中间是U。其中的Y是w * h,U和V是w/2 * (h/2)举例:如果w = 4,h = 2,则:yyyyyyyyuuvv即 yyyyyyyyuuvv采样规律是:每个像素点都采样Y,奇数行采样1/2个U,不采样V,偶数行采样1/2个V,不采样...

跨线程调用控件

vs2005中默认是不允许跨线程调用控件的,否则会出错。但是也有解决办法: 以下内容为转贴 在VS 2005  中考虑到线程的安全性,不允许跨线程调用控件!  为了解决这一问题   1. 将Control 的 CheckForIllegalCrossThreadCalls 属性设置为假, 不去捕获错误线程的调用,但这种做法是不安全的! 2.使用委托异...

浅析.Net下的多线程编程(1)

作者:peter 出处:天极论坛 多线程是许多操作系统所具有的特性,它能大大提高程序的运行效率,所以多线程编程技术为编程者广泛关注。 目前微软的.Net战略正进一步推进,各种相关的技术正为广大编程者所接受,同样在.Net中多线程编程技术具有相当重要的地位。本文我就向大家介绍在.Net下进行多线程编程的基本方法和步骤。 开始新线程 在.Net下创建一个新线...