zoukankan      html  css  js  c++  java
  • 任务

    1.创建任务有三种方式,使用TaskFactory类的StartNew()方法,Task类的构造函数,或者Task类的Start()方法。

    可以通过Action<object>委托和Func<>委托调用函数来实现一个Task任务

    Action委托调用的函数没有返回值

    Func委托调用的函数有一个返回值,当要返回多个值的时候,可以使用多元组来实现,例如:二元组Tuple<T1,T2>,T1,T2分别代表元素的类型

    2.连续的任务(一个任务完成立即调用另一个任务)

    可以通过Task类的ContinueWith()方法,TaskFactory类的OnContinueWith()方法来实现

    3.任务的结果(任务可以有返回类型 :Task.Result)

    如何实现有返回值的任务:使用泛型类Task<TResult>,第一个参数传给Func委托,第二个参数定义任务调用方法的输入参数,<TResult>为返回值的类型

    如下例:

    var t = new Task<Tuple<int, int>>(taskresult, Tuple.Create<int, int>(8, 8));

    Func委托taskresult方法,输入参数为Tuple.Create<int, int>(8, 8),返回类型为<Tuple<int, int>>

    且该输入参数包含在要调用方法(taskresult)的object obj参数中

    private static Tuple<int, int> taskresult(object obj)

    代码如下:

    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
    using System.Threading;
    
    namespace ConsoleApplication1
    {
        class Program
        {
            static void Main(string[] args)
            {
                //启动任务的3种不同方式,通过调用Action委托调用方法
                Task t1 = new Task(method1, TaskCreationOptions.PreferFairness);//TaskCreationOptions是枚举类型,PreferFairness表示以一种公平的方式处理任务,即先到先处理
                t1.Start();
    
                TaskFactory f = new TaskFactory();
                Task t2 = f.StartNew(method2, TaskCreationOptions.PreferFairness);
    
                Task t3 = Task.Factory.StartNew(method3, TaskCreationOptions.PreferFairness);
                //连续的任务
                Task s1 = t1.ContinueWith(second1);//s1在t1任务完毕后执行
                Task s2 = t1.ContinueWith(second2);//s2在t1任务完毕后执行
                Task s3 = s1.ContinueWith(second3, TaskContinuationOptions.OnlyOnRanToCompletion);//只有前面任务(s1)完成才执行安排的任务(s3)
                var t = new Task<Tuple<int, int>>(taskresult, Tuple.Create<int, int>(8, 8));//使用泛型类Task<TResult>,把taskresult方法传给Func委托,第二个参数定义了该方法输入的值
                t.Start();
                Console.WriteLine("                 "+t.Result);//t.Result表示t的返回值,只有任务完成t.Result才有效果
                t.Wait();//等待 Task t 完成执行过程。
                Console.WriteLine("                 task result:({0},{1})", t.Result.Item1,t.Result.Item2);//输出返回值二元组的值
                Thread.Sleep(10000);
                Console.WriteLine("                                main task is over!");
            }
    
            private static Tuple<int, int> taskresult(object obj)//object obj包含输入参数的信息
            {
                Console.WriteLine("                 task is beginning");
                Tuple<int,int> x=(Tuple<int,int>)obj;
                int a = x.Item1 / x.Item2;
                int b = x.Item1 * x.Item2;
                return Tuple.Create<int, int>(a, b);//创建一个二元组:Tuple.Create<int,int>(a,b)
            }
    
            private static void second1(Task t)
            {
                Console.WriteLine("second1 is beginning");
                Console.WriteLine("second1 id:{0}", Task.CurrentId);
                Thread.Sleep(2000);
                Console.WriteLine("second1 is end");
            }
            private static void second2(Task t)
            {
                Console.WriteLine("second2 is beginning");
                Console.WriteLine("second2 id:{0}", Task.CurrentId);
                Thread.Sleep(2000);
                Console.WriteLine("second2 is end");
            }
            private static void second3(Task t)
            {
                Console.WriteLine("second3 is beginning");
                Console.WriteLine("second3 id:{0}", Task.CurrentId);
                Thread.Sleep(2000);
                Console.WriteLine("second3 is end");
            }
            private static void method3()
            {
                Console.WriteLine("         Task3 is beginning");
                Thread.Sleep(2000);
                Console.WriteLine("         Task3 id:{0}", Task.CurrentId);
                Console.WriteLine("         Task3 is end");
            }
    
            private static void method2()
            {
                Console.WriteLine("    Task2 is beginning");
                Thread.Sleep(2000);
                Console.WriteLine("    Task2 id:{0}", Task.CurrentId);
                Console.WriteLine("    Task2 is end");
            }
    
            private static void method1()
            {
                Console.WriteLine("Task1 is beginning");
                Thread.Sleep(2000);
                Console.WriteLine("Task1 id:{0}", Task.CurrentId);
                Console.WriteLine("Task1 is end");
            }
        }
    }
  • 相关阅读:
    有一群志同道合的程序员朋友是怎样的体验?
    hdu1387 模拟队列
    hau 1870 愚人节的礼物(栈)
    hdu1509 优先队列
    hdu1837 看病要排队(优先队列)
    hdu 1237 简单计算器(栈处理)
    hdu1022 模拟栈
    又一个错误的认知!
    jmeter+ant+jenkins 接口自动化测试持续集成(送源码)
    P1197 [JSOI2008]星球大战
  • 原文地址:https://www.cnblogs.com/runninglzw/p/3844759.html
Copyright © 2011-2022 走看看