.NET 实现并行的几种方式(一)

好久没有更新了,今天来一篇,算是《同步与异步》系列的开篇吧,加油,坚持下去(PS:越来越懒了)。

一、Thread

利用Thread 可以直接创建和控制线程,在我的认知里它是最古老的技术了。因为out了、所以不再写例子了。

二、ThreadPool

由于线程的创建和销毁需要耗费大量的资源,为了提过性能、引入了线程池、即ThreadPool,ThreadPool 可隐式完成线程的创建和分配管理工作。

以下是来自MSDN的几句备注:

  线程池根据需要提供新的工作线程或 I/O 完成线程,直到其达到每个类别的最小值。 当达到最小值时,线程池可以在该类别中创建更多线程或等待某些任务完成。 从 .NET Framework 4 开始,线程池会创建和销毁工作线程以优化吞吐量,吞吐量定义为单位时间内完成的任务数。 线程过少时可能无法更好地利用可用资源,但线程过多时又可能会加剧资源的争用情况。

直接应用 ThreadPool时、有两种应用场景:

1、将需要异步执行的方法、排入队列,当有可用线程时执行被排入队列的方法

            // 该应用场景下 ThreadPool 提供如下两种形式的重载方法
            // public static bool QueueUserWorkItem(WaitCallback callBack);
            // public static bool QueueUserWorkItem(WaitCallback callBack, object state);

            // WaitCallback 为 delegate, 一个object类型的入参,没有返回值。
            // public delegate void WaitCallback(object state);

            base.SetTip(nameof(ThreadPool.QueueUserWorkItem));

            ThreadPool.QueueUserWorkItem((state) =>
            {
                this.SetTip("等待一秒");
                Thread.Sleep(1000);
                this.SetTip("任务执行完毕");
            });

2、注册等待信号对象(WaitHandle)、并在其收到信号或超时时触发回调函数

            // 该应用场景下 ThreadPool 提供了四种形式的重载方法, 下面的重载形式在我看来是最具有直观意义的
            // public static RegisteredWaitHandle RegisterWaitForSingleObject(
            //      WaitHandle waitObject, WaitOrTimerCallback callBack, object state, long millisecondsTimeOutInterval, bool executeOnlyOnce);

            // 其中 WaitHandle 为需要等待信号的类型 的 抽象基类,在后续随笔中会做详细介绍,在此不再多言。

            // 其中 WaitOrTimerCallback 为 回调函数委托
            // public delegate void WaitOrTimerCallback(object state, bool timedOut);

            // state 参数为 回调函数的传入参数

            // millisecondsTimeOutInterval 参数为 计时器超时周期, -1 为永不超时、即一直等待。
            // 对于此参数、第一次接触到的人可能有疑问、怎么还有周期?
            // 因为 信号可以重复接到多次、所以当每次接到信号后、或者超时后计时器都会重新计时, 所以有了周期的含义。

            // executeOnlyOnce, True 表示只执行一次, False 会一直等到该信号对象被取消注册,否则 只要接到信号或者超时就会触发回调函数。

            base.SetTip(nameof(ThreadPool.RegisterWaitForSingleObject));

            ThreadPool.RegisterWaitForSingleObject(this.waitObject, (state, timeout) =>
            {
                this.SetTip("++++++等待对象收到信号++++++");

            }, null, -1, false);

            ThreadPool.QueueUserWorkItem((state) =>
            {
                this.SetTip("等待一秒");
                Thread.Sleep(1000);

                this.SetTip("等待对象发出信号");
                this.waitObject.Set();

                this.SetTip("等待5秒");
                Thread.Sleep(5000);

                this.SetTip("等待对象发出信号");
                this.waitObject.Set();

            });

三、Delegate.BeginInvoke

Delegate.BeginInvoke 间接的调用了线程池、从线程池中获取一个可用线程、执行当前委托所指向的函数指针所代表的方法。

        [Tag("Delegate.BeginInvoke")]
        private void Demo3()
        {
            this.txtTip.SetTip("UI, Id:" + Thread.CurrentThread.ManagedThreadId);

            Action action = new Action(this.DelegateTest);
            action.BeginInvoke(null, null);
            action.BeginInvoke(null, null);            

        }

        private void DelegateTest()
        {
            int id = Thread.CurrentThread.ManagedThreadId;

            this.Dispatcher.Invoke(() =>
            {
                this.txtTip.SetTip("BeginInvoke, Id:" + id);
            });
        }

通过 Thread.CurrentThread.ManagedThreadId 、我们也可以间接的证明 BeginInvoke 确实时在不同的线程中执行的。

当然,与之对应的是一系列的 Begin...  End...  方法对, 它们都是 IAsyncResult 系列的异步编程模型中的一份子。

在 IAsyncResult  系列的异步编程模型中,传递参数 和 获取返回值的Demo 见下:

        [Tag("Delegate.BeginInvoke带有参数和返回值")]
        private void Demo4()
        {
            Func<string, string> func = new Func<string, string>(this.DelegateTest2);

            this.txtTip.SetTip(" 输入参数 123 ");

            func.BeginInvoke(" 123 ", new AsyncCallback((System.IAsyncResult result) =>
            {
                Func<string, string> tmp = result.AsyncState as Func<string, string>;
                if (tmp != null)
                {
                    string returnResult = tmp.EndInvoke(result);

                    this.Dispatcher.Invoke(() =>
                    {
                        this.txtTip.SetTip(" 函数回调 结果 : " + returnResult);
                    });
                }
            }), func);

        }
        private string DelegateTest2(string args)
        {
            return args + " : Return args";
        }

四、Task

Task是在 .NET 4.0 中新增的,是基于任务的异步模型。它是对线程池的再次封装、使得可以更加方便的创建多种任务组合,如 顺序性的延续任务、父子任务。也可以方便的粗粒度地控制任务优先级。

1)Task.NET 4.0 中提倡的方式

Task 对外公开了构造函数、但是微软并不建议直接使用Task构造函数去实例化对象,而是 使用 Task.Factory.StartNew();

MSDN 中的备注如下:
For performance reasons, TaskFactory‘s StartNew method should be the preferred mechanism for creating and scheduling computational tasks,
but for scenarios where creation and scheduling must be separated, the constructors may be used,
and the task‘s Start method may then be used to schedule the task for execution at a later time.
Task 类还提供了初始化任务但不计划执行任务的构造函数。 出于性能方面的考虑,TaskFactory 的 StartNew 方法应该是创建和计划计算任务的首选机制,
但是对于创建和计划必须分开的情况,可以使用构造函数,然后可以使用任务的 Start 方法计划任务在稍后执行。

            Task.Factory.StartNew(() =>
            {
                base.SetTip("Task.Factory.StartNew(一个参数)");
            }).ContinueWith((t) =>
            {
                base.SetTip(t.Id.ToString());
                base.SetTip(t.CreationOptions.ToString());
            }).ContinueWith((t) =>
            {
                base.SetTip(t.Id.ToString());
                base.SetTip(t.CreationOptions.ToString());
            });

// Task.Factory.StartNew 提供了高达16个的重载函数。
// 其中 Task.Factory.StartNew<TTask> 是创建带有返回值的异步任务。

// 以最复杂的重载为例、逐一介绍其参数
// public Task<TResult> StartNew<TResult>(Func<object, TResult> function, object state, CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskScheduler scheduler);

function : 回调函数、我想没有必要做解释吧。
state : 回调函数的传入参数
CancellationToken: 用以取消Task (后续随笔会做详细介绍)
TaskCreationOptions: 指定可控制任务的创建和执行的可选行为的标志(后续随笔会做详细介绍)
TaskScheduler: 一个实例 TaskScheduler 类表示一个任务计划程序. 该值一般都是使用 TaskScheduler.Default

也就是说:
Task.Factory.StartNew(()=> { });

Task.Factory.StartNew(()=> { }, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default);
两种方式效果是一致的。

如果你想更精细化的控制任务、可以使用其他重载方法、传递不同参数以达到预想的目的。

2)Task初始化任务但并不计划执行

前文说过 Task 提供了构造函数、它提供了初始化任务,但并不去计划执行的方式。
让我们再看一下 Task 得构造函数吧,还是以最复杂的为例:
public Task(Func<object, TResult> function, object state, CancellationToken cancellationToken, TaskCreationOptions creationOptions);
其参数和 Task.Factory.StartNew 相比、 少了TaskScheduler。在性能方面MSDN提示后者会更好。

            base.SetTip("初始化任务");
            Task task = new Task(() =>
            {
                base.SetTip("被计划的任务开始执行");

                base.SetTip("任务休眠5秒");
                Thread.Sleep(5000);

                base.SetTip("任务执行完毕");
            });

            // 为了保证能实时更新UI、看到代码执行效果、故而将代码异步执行
            Task.Factory.StartNew(() =>
            {
                base.SetTip("休眠两秒");
                Thread.Sleep(2000);

                base.SetTip("将任务列入执行计划");
                task.Start();

                base.SetTip("等待Task执行完毕");
                task.Wait();// Wait方法 会等待Task执行完毕
                base.SetTip("Task执行完毕");
            });

另外再强调一点:Task.Start(), 只是将任务列入执行计划,至于任务什么时候去执行则取决于线程池中什么时候有可用线程。
Task.Factory.StartNew 也是一样的。

好了,Task类的介绍、到此为止,后续随笔再做详细介绍:这个强大的Task类,还有很多值得我们去探索的东西。

本随笔到此、暂告一段落。

附,Demo : http://files.cnblogs.com/files/08shiyan/ParallelDemo.zip

参见更多:随笔导读:同步与异步

(未完待续...)

时间: 2024-11-10 06:46:45

.NET 实现并行的几种方式(一)的相关文章

.NET 实现并行的几种方式(二)

本随笔续接:.NET 实现并行的几种方式(一) 四.Task 3)Task.NET 4.5 中的简易方式 在上篇随笔中,两个Demo使用的是 .NET 4.0 中的方式,代码写起来略显麻烦,这不 .NET 4.5提供了更加简洁的方式,让我们来看一下吧. /// <summary> /// Task.NET 4.5 中的简易方式 /// </summary> public void Demo3() { Task.Run(() => { SetTip("简洁的代码&qu

.NET 实现并行的几种方式(三)

本随笔续接:.NET 实现并行的几种方式(二) 在前两篇随笔中,先后介绍了 Thread .ThreadPool .IAsyncResult (即 APM系列) .Task .TPL (Task Parallel Library). 写到这些笔者突然意识到 还有一个EMP系列没有写,在这里补充一下: 六. EPM .EPM中的典型代表是 WebClient: EPM系列采用 ***Async方法 + ***Completed事件 的编码规范,不做太多解释.具体的demo如下: var addre

Oracle并行更新的两种方式(merge/update内联视图)

对于Oracle的两表联合更新的场景(有A.B两表,以A.id=B.id关联,根据B表中的记录更新A表中的相应字段),一般有update内联视图和merge两种方式,下面举例介绍:   创建用例表: create table test1(id number(10),name varchar2(20)); create table test2(id number(10),name varchar2(20));   测试数据: begin insert into test1 values(1,'A'

单例模式创建的三种方式

一.单例模式的好处 1.对于频繁使用的对象,可以省略new操作花费的时间,这对于那些重量级对象而言,是非常可观的一笔系统开销: 2.由于new操作的次数减少,因而对系统内存的使用频率也会降低,这将减轻GC压力,缩短GC停顿时间. 二.创建方式 1)饿汉式 1 public class Singleton { 2     private Singleton(){ 3         System.out.println("Singleton is create"); 4     } 5 

JS异步加载的几种方式

一:同步加载 我们平时使用的最多的一种方式. <script src="http://yourdomain.com/script.js"></script> <script src="http://yourdomain.com/script.js"></script> 同步模式,又称阻塞模式,会阻止浏览器的后续处理,停止后续的解析,只有当当前加载完成,才能进行下一步操作.所以默认同步执行才是安全的.但这样如果js中有输

javascript脚本异步加载的几种方式

一般而言,javascript脚本一般是建议放在body标签的底部,因为使用script标签加载js时,会停止加载后面的内容而停下来解析脚本并对页面进行渲染,使用src属性加载外部脚本也会造成这样的情况,这样的话,如果在head或者body的前面放入过多的script标签,并且内容很多的时候,会造成页面在解析完所有script标签的内容前有短暂的时间整个页面空白,给用户的体验会很差.但是如果所有的脚本都放在底部,又会造成dom加载完毕后有一段时间页面虽然能看到,但是和用户的交互却很差,因此需要让

在基于MVC的Web项目中使用Web API和直接连接两种方式混合式接入

在我之前介绍的混合式开发框架中,其界面是基于Winform的实现方式,后台使用Web API.WCF服务以及直接连接数据库的几种方式混合式接入,在Web项目中我们也可以采用这种方式实现混合式的接入方式,虽然Web API或者WCF方式的调用,相对直接连接数据库方式,响应效率上略差一些,不过扩展性强,也可以调动更多的设备接入,包括移动应用接入,网站接入,Winfrom客户端接入,这样可以使得服务逻辑相对独立,负责提供接口即可.这种方式中最有代表性的就是当前Web API的广泛应用,促进了各个接入端

Java并发编程-创建线程的两种方式及区别

转载请注明:http://blog.csdn.net/UniKylin/article/details/45016117 1.线程和进程的区别 并行:是多个任务在同一时间同时执行,例如多核计算机同时计算的任务可以理解为并行 并发:从微观上看是多个任务抢占一个CPU从而执行自己的任务,轮流执行任务,但是如果遇到资源冲突的时候并没有从根本提高执行效率.但是提高了CPU的使用效率. 前段时间在GitHub上的一幅图可以很好的阐述上面的概念非常形象 2.Java中创建线程的两种方式 1.第一种方式:直接

Java接入Spark之创建RDD的两种方式和操作RDD

首先看看思维导图,我的spark是1.6.1版本,jdk是1.7版本 spark是什么? Spark是基于内存计算的大数据并行计算框架.Spark基于内存计算,提高了在大数据环境下数据处理的实时性,同时保证了高容错性和高可伸缩性,允许用户将Spark 部署在大量廉价硬件之上,形成集群. 下载和安装 可以看我之前发表的博客 Spark安装 安装成功后运行示例程序 在spark安装目录下examples/src/main目录中. 运行的一个Java或Scala示例程序,使用bin/run-examp