第五节:Task构造函数之TaskCreationOptions枚举处理父子线程之间的关系。

一. 整体说明

揭秘:

  通过F12查看Task类的源码(详见下面的截图),发现Task类的构造函数有有一个参数为:TaskCreationOptions类型,本章节可以算作是一个扩展章节,主要就来研究TaskCreationOptions类的作用。

  该类主要用来处理父子线程之间的关系,重要的几个参数如下: 

  ①.AttachedToParent:指定将任务附加到任务层次结构中的某个父级,父任务必须等待所有子任务执行完毕才能执行

    (下面的例子task线程必须等task1和task2线程执行完毕才能执行)

  ②. DenyChildAttach: 不允许子任务附加到父任务上

    (下面例子task不再等待task1和task2,和00的默认效果相同)

  ③. HideScheduler: 子任务不使用父类Task的Scheduler,而是使用默认的 (不进行测试)

  ④. LongRunning:当已知是长时间运行的任务,可以使用该选项 (不进行测试)

  ⑤. PreferFairness:类似于队列的感觉,尽可能公平的方式安排任务 (不进行测试)

 源码如下:

复制代码

 1  // 摘要: 2     //     指定可控制任务的创建和执行的可选行为的标志。3     [Serializable]4     [Flags]5     public enum TaskCreationOptions6     {7         // 摘要: 8         //     指定应使用默认行为。9         None = 0,
10         //
11         // 摘要: 
12         //     提示 System.Threading.Tasks.TaskScheduler 以一种尽可能公平的方式安排任务,这意味着较早安排的任务将更可能较早运行,而较晚安排运行的任务将更可能较晚运行。
13         PreferFairness = 1,
14         //
15         // 摘要: 
16         //     指定某个任务将是运行时间长、粗粒度的操作。 它会向 System.Threading.Tasks.TaskScheduler 提示,过度订阅可能是合理的。
17         LongRunning = 2,
18         //
19         // 摘要: 
20         //     指定将任务附加到任务层次结构中的某个父级。
21         AttachedToParent = 4,
22         //
23         // 摘要: 
24         //     如果尝试附有子任务到创建的任务,指定 System.InvalidOperationException 将被引发。
25         DenyChildAttach = 8,
26         //
27         // 摘要: 
28         //     防止环境计划程序被视为已创建任务的当前计划程序。 这意味着像 StartNew 或 ContinueWith 创建任务的执行操作将被视为 System.Threading.Tasks.TaskScheduler.Default
29         //     当前计划程序。
30         HideScheduler = 16,
31     }

复制代码

 

二. 实际测试

   这里我们主要通过代码来比较默认情况下、AttachedToParent、DenyChildAttach之间的效果, task线程内部有task1和task2线程,并且在task内部开启。

1. 默认情况

复制代码

 1         {2             Stopwatch watch = new Stopwatch();3             watch.Start();4             Console.WriteLine("----------------- Task多线程测试  --------------------------");5             Console.WriteLine("----------------- button1_Click 开始 主线程id为:{0}  --------------------------", Thread.CurrentThread.ManagedThreadId);6 7             #region 00-默认8             {9                 Task task = new Task(() =>
10                 {
11                     Task task1 = new Task(() =>
12                     {
13                         Thread.Sleep(1000);
14                         Console.WriteLine("我是task1线程");
15                     });
16                     Task task2 = new Task(() =>
17                     {
18                         Thread.Sleep(1000);
19                         Console.WriteLine("我是task2线程");
20                     });
21 
22                     task1.Start();
23                     task2.Start();
24                 });
25 
26                 task.Start();
27                 task.Wait();   //单个线程的等待
28                 Console.WriteLine("------------------我是主线程--------------------");
29             }
30             #endregion
31 
32             watch.Stop();
33             Console.WriteLine("----------------- button1_Click 结束 主线程id为:{0}  总耗时:{1}--------------------------", Thread.CurrentThread.ManagedThreadId, watch.ElapsedMilliseconds);
34         }

复制代码

  多次执行上述代码看效果:发现task线程执行完后,task1和task2才无序的执行。

2. AttachedToParent

  作用:指定将任务附加到任务层次结构中的某个父级,父任务必须等待所有子任务执行完毕才能执行

复制代码

 1          {2                 Task task = new Task(() =>3                 {4                     Task task1 = new Task(() =>5                     {6                         Thread.Sleep(3000);7                         Console.WriteLine("我是task1线程");8                     }, TaskCreationOptions.AttachedToParent);9                     Task task2 = new Task(() =>
10                     {
11                         Thread.Sleep(3000);
12                         Console.WriteLine("我是task2线程");
13                     }, TaskCreationOptions.AttachedToParent);
14 
15                     task1.Start();
16                     task2.Start();
17                 });
18 
19                 task.Start();
20                 task.Wait();   //单个线程的等待
21                 Console.WriteLine("------------------我是主线程--------------------");
22             }

复制代码

   多次执行上述代码看效果:发现task线程必须等task1和task2执行完毕后才能执行(印证了AttachedToParent的作用),task1和task2无先后顺序。

3. DenyChildAttach

   作用:不允许子任务附加到父任务上。

复制代码

 1  {2                 Task task = new Task(() =>3                 {4                     Task task1 = new Task(() =>5                     {6                         Thread.Sleep(3000);7                         Console.WriteLine("我是task1线程");8                     }, TaskCreationOptions.AttachedToParent);9                     Task task2 = new Task(() =>
10                     {
11                         Thread.Sleep(3000);
12                         Console.WriteLine("我是task2线程");
13                     }, TaskCreationOptions.AttachedToParent);
14 
15                     task1.Start();
16                     task2.Start();
17                 }, TaskCreationOptions.DenyChildAttach);
18 
19                 task.Start();
20                 task.Wait();   //单个线程的等待
21                 Console.WriteLine("------------------我是主线程--------------------");
22             }

复制代码

 多次执行上述代码看效果:发现task线程执行完后,task1和task2才无序的执行。(和上述的默认情况是一致的)

 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/438259.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

List,Map,实体类,字符串相互转换

添加依赖 <dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.7</version></dependency> List,实体类字符串想换转换 package Map;import com.alibaba.fastjson.*; import dto.Pers…

第六节:深入研究Task实例方法ContinueWith的参数TaskContinuationOptions

一. 整体说明 揭秘&#xff1a; 该章节的性质和上一个章节类似&#xff0c;也是一个扩展的章节&#xff0c;主要来研究Task类下的实例方法ContinueWith中的参数TaskContinuationOptions。 通过F12查看TaskContinuationOptions的源码&#xff0c;知道主要有这么几个参数&#xf…

java8 stream流操作集合交集,差集,并集,过滤,分组,去重,排序,聚合等

测试对象 public class Person {private String name;private Integer age;private Integer weight;public Person() {}public Integer getWeight() {return weight;}public void setWeight(Integer weight) {this.weight weight;}public Integer getAge() {return age…

第七节:利用CancellationTokenSource实现任务取消和利用CancellationToken类检测取消异常。

一. 传统的线程取消 所谓的线程取消&#xff0c;就是线程正在执行的过程中取消线程任务。 传统的线程取消&#xff0c;是通过一个变量来控制&#xff0c;但是这种方式&#xff0c;在release模式下&#xff0c;被优化从cpu高速缓存中读取&#xff0c;而不是从内存中读取&#xf…

start()和run()的区别

start方法&#xff1a; 通过该方法启动线程的同时也创建了一个线程&#xff0c;真正实现了多线程。无需等待run()方法中的代码执行完毕&#xff0c;就可以接着执行下面的代码。此时start()的这个线程处于就绪状态&#xff0c;当得到CPU的时间片后就会执行其中的run()方法。这个…

c#中的BeginInvoke和EndEndInvoke 摘要

摘要 异步这东西&#xff0c;真正用起来的时候&#xff0c;发现事情还是挺多的&#xff0c;最近在项目中用到了异步的知识&#xff0c;发现对它还是不了解&#xff0c;处理起来&#xff0c;走了不少弯路。觉得还是补一补还是很有必要的。 MSDN原文地址&#xff1a;https://ms…

关于@DateTimeFormat 和 @JsonFormat 注解

两个参数都是针对日期格式化做处理 1.入参格式化DateTimeFormat 传入参数是 String 类型,接收的参数Date 类型&#xff0c;类型无法转换。 使用 Spring 的 DateTimeFormat 注解格式化参数 传入参数要是日期格式的String 类型 例如:"2021-10-01" pattern &quo…

NET 提供了执行异步操作的三种模式

1.APM模式简介 在.net1.x的版本中就可以使用IAsyncResult接口实现异步操作&#xff0c;但是比较复杂&#xff0c;这种称之为异步编程模型模式 (Asynchronous Programming Model, APM)&#xff0c;也称为IAsyncResult模式 在这种APM模式下&#xff0c;一个同步操作XXX需要定义B…

java实体类属性非空判断工具类

import java.util.Collection; import java.util.HashMap; import java.util.Map; import java.util.Map.Entry;public class CheckParametersUtil {Map<String, Object> map new HashMap<>();/*** 添加需要校验的参数* param object 实参* param parameterName 参…

第八节:Task的各类TaskTResult返回值以及通用线程的异常处理方案。

一. Task的各种返回值-Task<TResult> PS&#xff1a; 在前面章节&#xff0c;我们介绍了Task类开启线程、线程等待、线程延续的方式&#xff0c;但我们并没有关注这些方式的返回值&#xff0c;其实他们都是有返回值的Task<TResult>&#xff0c;然后可以通过Task的…

第九节:深究并行编程Parallel类中的三大方法 (For、ForEach、Invoke)和几大编程模型(SPM、APM、EAP、TAP)

一. 并行编程 1. 区分串行编程和串行编程 ①. 串行编程&#xff1a;所谓的串行编程就是单线程的作用下&#xff0c;按顺序执行。(典型代表for循环 下面例子从1-100按顺序执行) ②. 并行编程&#xff1a;充分利用多核cpu的优势&#xff0c;同时开启多个线程并行执行。(典型代表…

Mybatis四种分页方式

1.数组分页 查询出全部数据&#xff0c;然后再list中截取需要的部分。 mybatis接口 List<Student> queryStudentsByArray(); xml配置文件 <select id"queryStudentsByArray" resultMap"studentmapper">select * from student</select&…

第十节:利用async和await简化异步编程模式的几种写法

一. async和await简介 PS&#xff1a;简介 1. async和await这两个关键字是为了简化异步编程模型而诞生的&#xff0c;使的异步编程更简洁&#xff0c;它本身并不创建新线程&#xff0c;但在该方法内部开启多线程&#xff0c;则另算。 2. 这两个关键字适用于处理一些文件IO操作。…

第十一节:深究用户模式锁的使用场景(异变结构、互锁、旋转锁)

一. 锁机制的背景介绍 本章节&#xff0c;将结合多线程来介绍锁机制&#xff0c; 那么问题来了&#xff0c;什么是锁呢&#xff1f; 为什么需要锁&#xff1f; 为什么要结合多线程来介绍锁呢&#xff1f;锁的使用场景又是什么呢&#xff1f; DotNet中又有哪些锁呢&#xff1f; …

第十三节:实际开发中使用最多的监视锁Monitor、lock语法糖的扩展、混合锁的使用(ManualResetEvent、SemaphoreSlim、ReaderWriterLockSlim)

一. 监视锁(Monitor和lock) 1. Monitor类&#xff0c;限定线程个数的一把锁&#xff08;Synchronized lock是他的语法糖&#xff09;&#xff0c;两个核心方法&#xff1a; Enter&#xff1a;锁住某个资源。 Exit&#xff1a;退出某一个资源。 测试案例&#xff1a;开启5个线…

什么是Mybatis ?

使用JDBC连接数据库 半自动持久层的ORM框架(因为要自己手写sql) 可以使用xml配置,可以使用注解. 优点:1.低耦合,sql重用,编写灵活 2.减少冗余代码 3.兼容数据库 4.能很好的与spring集成 5.提供映射标签,支持对象与数据库的ORM字段映射 缺点:1.sql需要自己编写 2数据库移植性…

第十四节: 介绍四大并发集合类并结合单例模式下的队列来说明线程安全和非安全的场景及补充性能调优问题。

一. 四大并发集合类 背景&#xff1a;我们目前使用的所有集合都是线程不安全的 。 A. ConcurrentBag&#xff1a;就是利用线程槽来分摊Bag中的所有数据&#xff0c;链表的头插法,0代表移除最后一个插入的值. (等价于同步中的List) B. ConcurrentStack&#xff1a;线程安全的St…

#{} 跟${}的区别

#{}是预编译处理 ,可以防止sql注入 ,提高安全性 mybatis 会把sql中的#{}替换成? 调用PreparedStatement set方法赋值 ${}是字符串替换 mybatis会把${}直接替换成变量值

第十五节:深入理解async和await的作用及各种适用场景和用法

一. 同步VS异步 1. 同步 VS 异步 VS 多线程 同步方法&#xff1a;调用时需要等待返回结果&#xff0c;才可以继续往下执行业务 异步方法&#xff1a;调用时无须等待返回结果&#xff0c;可以继续往下执行业务 开启新线程&#xff1a;在主线程之外开启一个新的线程去执行业…

@PostConstruct注解

PostConstruct是Java自己的注解. PostConstruct该注解被用来修饰一个非静态的void()方法. PostConstruct修饰的方法会在服务器加载Servlet的时候运行,并且只会被服务器执行一次. PostConstruct在构造函数之后执行,init()方法之前执行. 执行顺序 Constructor >> Autow…