多线程之任务

  Parallel类(http://www.cnblogs.com/afei-24/p/6904179.html)的并行任务需要结束后才能运行后面的代码,如果想不等结束后在开始动作,可以使用Task类更好地控制并行动作。
  任务表示应完成的某个工作单元。这个工作单元可以在单独的线程中运行,也可以以同步方式启动一个任务,这需要等待主调线程。使用任务不仅可以获得一个抽象层,还可以对底层线程进行很多控制。
  任务相对Parallel类提供了非常大的灵活性。例如,可以定义连续的工作——在一个任务完成后该执行什么工作。这可以根据任务成功与否来分。还可以在层次结构中安排任务。例如,父任务可以创建新的子任务。

一.启动任务
  要启动任务,可以使用TaskFactory类或Task类的构造函数和Start()方法。Task类的构造函数在创建任务上灵活性比较大。
  在启动任务时,会创建Task类的一个实例,利用Action或Action<T>委托(不带参数或带一个参数),可以指定应运行的代码。

  1.使用线程池的任务
  线程池提供了一个后台线程的池(后面详细介绍了线程池)。线程池独自管理线程,根据需要增加或减少线程池中的线程数。线程池中的线程用于实现一些动作,之后仍然返回线程池中。

  下面介绍创建线程池的任务的四种方法:
  先定义一个要调用使用的方法:

  //避免写入控制台的操作交叉,这里使用lock关键字同步
        static object taskMethodLock = new object();
        static void TaskMethod(object title)
        {
            lock (taskMethodLock)
            {
                Console.WriteLine(title);
                Console.WriteLine("task id:{0},thread:{1}",Task.CurrentId,Thread.CurrentThread.ManagedThreadId);
                Console.WriteLine("is pooled thread:{0}",Thread.CurrentThread.IsThreadPoolThread);
                Console.WriteLine("is background thread:{0}",Thread.CurrentThread.IsBackground);
            }
        }

  (1).使用实例化的TaskFactory类,把TaskMethod方法和TaskMethod方法的参数传递给StartNew方法:
    var tf = new TaskFactory();
    Task t1 = tf.StartNew(TaskMethod,"using a task factory");

  (2).使用Task类的静态属性Factory来访问TaskFactory,以调用StartNew()方法。类似第一种,也使用了工厂,但对工厂的控制没那么全面。
    Task t2 = Task.Factory.StartNew(TaskMethod,"using factory via a task");

  (3).使用Task的构造函数。实例化Task对象时任务不会执行,只是指定Created状态。接着调用Start()方法,启动任务。
    Task t3 = new Task(TaskMethod,"using a task constructor and Start");
    t3.Start();

  (4).直接调用Task类的Run()方法启动任务。Run()方法没有传递带参数委托的版本,可以通过传递lambda表达式。
    Task t4 = Task.Run(()=> TaskMethod("using Run method"));

  static void Main(string[] args)
        {
            var tf = new TaskFactory();
            Task t1 = tf.StartNew(TaskMethod,"using a task factory");

            Task t2 = Task.Factory.StartNew(TaskMethod,"using factory via a task");

            Task t3 = new Task(TaskMethod,"using a task constructor and Start");
            t3.Start();

            Task t4 = Task.Run(()=> TaskMethod("using Run method"));

            Console.ReadKey();
        }

  2.同步任务
  任务不一定使用线程池中的线程,也可以使用其它线程。任务也可以同步运行,以相同的线程作为主调线程。
  示例:

      static void RunSyncTask()
            {
                TaskMethod("main thread");
                var t = new Task(TaskMethod,"run sync");
                t.RunSynchronously();
            }

  输出:
  

  上面代码先在主线程上直接调用TaskMethod方法,然后在创建的Task上调用。从输出看到,主线程是一个前台线程,没有任务ID,也不是线程池中的线程。调用RunSynchronously方法时,会使用相同的线程,会创建一个任务。

  3.使用单独线程的任务
  上面将到的任务虽然不是线程池中的线程,但使用的是主线程,不是单独的,不能实现异步。
  如果任务的代码应该长时间运行,就应该使用TaskCreationOptions.LongRunning告诉任务调度器创建一个新的单独线程,而不是线程池中的线程。这个线程可以不由线程池管理。当线程来自线程池时,任务调度器可以决定等待已经运行的任务完成,然后使用这个线程,而不是在线程池中创建一个新线程。对于长时间运行的线程,任务调度器会立即知道等待它们完成是不明智的做法,会创建一个新的线程。

  示例:

      static void LongRunTask()
            {
                var t = new Task(TaskMethod,"long running",TaskCreationOptions.LongRunning);
                t.Start();
            }

  输出:
  

二.任务的结果————Future
  任务结束时,可以把一些有用的状态信息写入共享对象中。这个共享对象必须是线程安全的。另一个选项是使用返回某个结果的任务。这种任务也叫future,因为它在将来返回一个结果。这需要使用Task类的一个泛型版本。使用这个类可以定义任务返回的结果的类型。
  示例:
  使用泛型类Task<TResult>,TResult是返回类型。通过构造函数,把方法传递给Func委托,第二个参数是委托的参数。

      static void Main(string[] args)
            {
                var t = new Task<Tuple<int, int>>(TaskWithResult,Tuple.Create<int,int>(8,3));
                t.Start();
                Console.WriteLine(t.Result);
                t.Wait();
                Console.WriteLine("result from task:{0},{1}", t.Result.Item1, t.Result.Item2);

                Console.ReadKey();
            }

  由任务来调用来返回结果的方法可以声明为任何类型。

static Tuple<int, int> TaskWithResult(object o)
        {
            Tuple<int, int> div = (Tuple<int, int>)o;
            int result = div.Item1 / div.Item2;
            int reminder = div.Item1 % div.Item2;
            Thread.Sleep(10000);
            return Tuple.Create<int, int>(result,reminder);
        }

  这里使用了元组(http://www.cnblogs.com/afei-24/p/6738155.html).

三.连续的任务
  通过任务,可以指定在任务完成后,应接着运行另一个特定任务。例如,一个使用前一个任务的结果的新任务,如果前一个任务失败了,这个任务就应执行一些清理工作。
  任务处理程序(前一个任务)或者不带参数,或者带一个对象参数,而连续处理程序有一个Task类型的参数,这里可以访问前一个任务的相关信息。
  示例:

//一个任务结束时,可以启动多个任务,连续任务也可以有另一个连续的任务。
        static void Main(string[] args)
        {
            Task t1 = new Task(DoFirst);
            Task t2 = t1.ContinueWith(DoSecond);
            Task t3 = t1.ContinueWith(DoSecond);
            Task t4= t2.ContinueWith(DoSecond);
            t1.Start();
            Console.ReadKey();

        }

        static void DoFirst()
        {
            Console.WriteLine("do some task:{0}",Task.CurrentId);
            Thread.Sleep(3000);
        }
        static void DoSecond(Task t)
        {
            Console.WriteLine("task {0} finished",t.Id);
            Console.WriteLine("this task id:{0}",Task.CurrentId);

        }

  无论前一个任务是如何结束,前面的连续任务总是在前一个任务结束时启动。使用TaskContinuationOptions枚举中的值,可以指定,连续任务只有在任务成功或失败时启动。
    Task t5 = t1.ContinueWith(DoSecond,TaskContinuationOptions.OnlyOnFaulted);

四.任务的层次结构
  利用任务连续性,可以在一个任务结束后启动另一个任务。任务也可以构成一个层次结构。在一个任务中启动一个新的任务时,就启动了一个父/子层次结构。取消父任务,也会取消子任务。
  创建子任务与创建父任务的代码相同,唯一区别就就是子任务从另一个任务内部创建。
  示例:

static void Main(string[] args)
        {
            Task t = new Task(ParentTask);
            t.Start();
            Console.ReadKey();

        }

        static void ParentTask()
        {
            Console.WriteLine("parent task id:{0}",Task.CurrentId);
            var child = new Task(ChildTask);
            child.Start();
            Console.WriteLine("parent  create child");
        }

        static void ChildTask()
        {
            Console.WriteLine("child task");

        }

  如果父任务在子任务之前结束,父任务的状态就是WaitingForChildrenToComplete。所有子任务也结束时,父任务的状态就是RanToCompletion.

时间: 2024-10-08 08:34:34

多线程之任务的相关文章

Java多线程学习(吐血超详细总结)

林炳文Evankaka原创作品.转载请注明出处http://blog.csdn.net/evankaka 目录(?)[-] 一扩展javalangThread类 二实现javalangRunnable接口 三Thread和Runnable的区别 四线程状态转换 五线程调度 六常用函数说明 使用方式 为什么要用join方法 七常见线程名词解释 八线程同步 九线程数据传递 本文主要讲了java中多线程的使用方法.线程同步.线程数据传递.线程状态及相应的一些线程函数用法.概述等. 首先讲一下进程和线程

Spring多线程

Spring是通过TaskExecutor任务执行器来实现多线程和并发编程的.使用ThreadPoolTaskExecutor可实现一个基于线程池的TaskExecutor.而实际开发中任务一般是非阻碍的,即异步的,所以我们要在配置类中通过@EnableAsync开启对异步的支持,并通过在实际执行的Bean的方法中使用@Async注解来声明其是一个异步任务. 实例代码: (1)配置类 package com.lwh.highlight_spring4.ch3.taskexecutor; /**

python进阶学习(一)--多线程编程

1. 多线程 概念:简单地说操作系统可以同时执行多个不用程序.例如:一边用浏览器上网,一边在听音乐,一边在用笔记软件记笔记. 并发:指的是任务数多余cpu核数,通过操作系统的各种任务调度算法,实现用多个任务"一起"执行(实际上总有一些任务不在执行,因为切换任务的熟度相当快,看上去一起执行而已) 并行:指的是任务数小于等于CPU核数,即任务真的是一起执行的. 2. 线程 概念:线程是进程的一个实体,是CPU调度和分派的基本单位. threading--单线程执行: 1 import ti

多线程的实现及其安全问题

一.进程和线程概述 1.进程:进程是一个具有独立功能的程序关于某个数据集合的一次运行活动,简单来说开启一个程序就开启了一个进程: 如果开启多个进程,它们之间是由于CPU的时间片在相互的切换: 2.线程:开启一个进程的一个任务,对于多线程:每一个线程都在争夺CPU的执行权(CPU的执行权具有随机性): 如果一个程序的执行路径有多条,那么该线程是多线程;反之,就单线程线程:线程是依赖于进程存在的! 3.Jvm是多线程 -- 至少开启了两条线程 main方法 主线程 gc() 垃圾回收线程 二.多线程

多线程和多进程的区别与联系

1.单进程单线程:一个人在一个桌子上吃菜.2.单进程多线程:多个人在同一个桌子上一起吃菜.3.多进程单线程:多个人每个人在自己的桌子上吃菜. 多线程的问题是多个人同时吃一道菜的时候容易发生争抢,例如两个人同时夹一个菜,一个人刚伸出筷子,结果伸到的时候已经被夹走菜了...此时就必须等一个人夹一口之后,在还给另外一个人夹菜,也就是说资源共享就会发生冲突争抢. 1.对于 Windows 系统来说,[开桌子]的开销很大,因此 Windows 鼓励大家在一个桌子上吃菜.因此 Windows 多线程学习重点

Python有了asyncio和aiohttp在爬虫这类型IO任务中多线程/多进程还有存在的必要吗?

最近正在学习Python中的异步编程,看了一些博客后做了一些小测验:对比asyncio+aiohttp的爬虫和asyncio+aiohttp+concurrent.futures(线程池/进程池)在效率中的差异,注释:在爬虫中我几乎没有使用任何计算性任务,为了探测异步的性能,全部都只是做了网络IO请求,就是说aiohttp把网页get完就程序就done了. 结果发现前者的效率比后者还要高.我询问了另外一位博主,(提供代码的博主没回我信息),他说使用concurrent.futures的话因为我全

多线程(一)

这边来谈谈java中,我对对多线程的理解 在了解多线程前,先说说进程. 进程就是正在运行的应用程序.  当你打开任务管理器的时候,你就会发现很多的进程. 而我们要说的线程,就是依赖于进程而存在的,一个进程可以开启多个线程. Thread类 说到线程,就必须来说说Thread类. Thread类是说有线程的父类.具体请参见api 线程的创建以及执行(图解如下) 继承Thread类,或者实现rennable接口. 当继承了父类后,需要重写父类的run方法,这个run方法里面就写你要执行的代码,当这个

多线程下的单例-double check

话不多说直接上代码: public sealed class Singleton { private static Singleton _instance = null; // Creates an syn object. private static readonly object SynObject = new object(); Singleton() { } public static Singleton Instance { get { // Double-Checked Lockin

笔记:多线程

多线程程序在较低的层次上扩展了多任务的概念:一个程序同时执行多个任务,通常每个任务称为一个线程(thread),他是线程控制的简称,可以同时运行一个以上线程的程序称为多线程程序(multithreaded):多线程和多进程有哪些区别呢,本质的区别在于每个进程拥有自己的一整套变量,而线程则是共享数据,Java中启动一个线程的代码如下: // 线程任务的具体实现接口 ????public interface Runnable { public abstract void run(); ????} /

多线程

1.线程的概念? 多线程,就类似与操作系统中的多进程.简单的讲,就是可 以同时并发执行多个任务,处理多件事情.这与我们经常所 谓的边唱边跳,边说边做事一个道理.? 线程是一个轻量级的进程,一个进程中可以分为多个线程. 比起进程,线程所耗费的系统资源更少,切换更加容易 /* * 进程是操作系统中的一个任务,一个程序启动运行,就会创建 * 一个(或多个)进程. * 线程是轻量级的进程.进程会有自己独立的内存空间与资源.一个进程 * 下会存在一个(或多个)线程.线程为进程的执行单元.线程本身不含有 *