[C#并发编程学习笔记].NET 异步操作执行中显示执行进度,并可取消异步操作

在异步方法执行过程中报告进度可以使用Progress<T>类型,创建一个Progress<T>类型的实例,并为它添加报告事件,作为参数传入异步方法中。上代码:

我们需要调用的异步方法:

 1 /// <summary>
 2 /// 报告进度并且可取消的异步任务
 3 /// </summary>
 4 /// <param name="token"></param>
 5 /// <param name="progress"></param>
 6 /// <returns></returns>
 7 public static async Task ProgressAsync(CancellationToken token, IProgress<double> progress = null)
 8 {
 9   double percentComplete = 0;
10   //进度未达到100%时循环执行,模拟一个长时间执行的任务
11   while (percentComplete<=100)
12   {
13     //判断取消标记
14     if (token.IsCancellationRequested)
15       return;
16     //报告给调用者
17     progress?.Report(percentComplete);
18     await Task.Delay(TimeSpan.FromSeconds(1));
19     percentComplete += 10;
20   }
21 }

调用方法:

 1 static readonly CancellationTokenSource Token = new CancellationTokenSource();
 2
 3 /// <summary>
 4 /// 调用报告进度的方法
 5 /// </summary>
 6 /// <returns></returns>
 7 private async static Task ProgressTest(){
 8   //创建progress实例
 9   var progress=new Progress<double>();
10   //添加报告时的响应事件
11   progress.ProgressChanged += (sender, args) =>
12   {
13     Console.WriteLine($"当前进度{args}%");
14   };
15   //调用报告方法
16   await Charpt1.Charpt1.ProgressAsync(Token.Token, progress);
17 }

执行的Main方法如下:

 1 static void Main(string[] args)
 2 {
 3   ProgressTest();
 4   var key = Console.ReadKey();
 5   //当输入字符为j时取消任务
 6   if (key.KeyChar == ‘j‘)
 7   {
 8     Token.Cancel();
 9     Console.WriteLine("任务被取消!");
10   }
11   Console.ReadLine();
12 }

当我们不取消任务时,可以看到以下结果

在执行过程中输入‘j‘,以取消任务,结果如下:

时间: 2024-07-30 09:44:08

[C#并发编程学习笔记].NET 异步操作执行中显示执行进度,并可取消异步操作的相关文章

Java并发编程学习笔记

Java编程思想,并发编程学习笔记. 一.基本的线程机制 1.定义任务:Runnable接口 线程可以驱动任务,因此需要一种描述任务的方式,这可以由Runnable接口来提供.要想定义任务,只需实现Runnable接口并编写run方法,使得该任务可以执行你的命令.   class MyTask implements Runnable {    private String mName;     public MyTask(String name) {    mName = name;   }  

Java并发编程学习笔记(一)线程安全性 1

什么是线程安全性: 要编写线程安全的代码,其核心在于要对状态访问操作进行管理,特别是对共享的和可变的状态的访问."共享"意味着变量可以由多个线程同时访问,而"可变"则意味着变量的值在其生命周期内可以发生变化. 一个对象是否需要线程安全的,取决于他是否被多个线程访问.这指的是在程序中访问对象的方式,而不是对象要实现的功能.要使得对象时线程安全的,需要采用同步机制来协同对对象可变状态的访问.如果无法实现协同,那么可能导致数据破坏以及其他不该出现的结果. 如果当多个线程访

第十二章 并发编程 学习笔记

第十二章 并发编程 进程是程序级并发,线程是函数级并发. 三种基本的构造并发程序的方法: 进程:每个逻辑控制流是个一个进程,由内核进行调度和维护. I/O多路复用:应用程序在一个进程的上下文中显式地调度他们自己的逻辑流. 线程:运行在单一进程上下文中的逻辑流,由内核进行调度. 12.1 基于进程的并发编程 构造并发程序最简单的方法就是用进程. 使用大家都很熟悉的函数例如: fork exec waitpid 关于在父.子进程间共享状态信息:共享文件表,但不共享用户地址空间. 进程又独立的地址空间

java并发编程学习:如何等待多个线程执行完成后再继续后续处理(FutureTask、synchronized、CyclicBarrier)

多线程应用中,经常会遇到这种场景:后面的处理,依赖前面的N个线程的处理结果,必须等前面的线程执行完毕后,后面的代码才允许执行. 在我不知道CyclicBarrier之前,最容易想到的就是放置一个公用的static变量,假如有10个线程,每个线程处理完上去累加下结果,然后后面用一个死循环(或类似线程阻塞的方法),去数这个结果,达到10个,说明大家都爽完了,可以进行后续的事情了,这个想法虽然土鳖,但是基本上跟语言无关,几乎所有主流编程语言都支持. package yjmyzz.test; publi

Java并发编程学习笔记(一)——线程安全性

1.当多个线程访问某个状态变量并且其中有一个献策灰姑娘执行写入操作时,必须采用同步机制来协同这些线程对变量的访问.Java中的主要同步机制是关键字synchronized,他提供了一种独占的加锁方式. 2.在任何情况下,只有当类中仅包含自己的状态时,线程安全类才是有意义的. 3.当多个线程访问某个类时,不管运行时环境采用何种调度方式或者这些献策灰姑娘讲如何交替执行,并且在主调代码中不需要任何额外的同步或协同,这个类都能表现出正确的行为,那么就称这个类是线程安全的. 4.无状态对象一定是线程安全的

C++并发编程学习笔记&lt;1&gt; 开始入门

开始入门 一个多线程C++程序是什么样子的? 它看上去和其他所有C++程序一样,通常是变量.类以及函数的组合.唯一真正的区别在于某些函数可以并发运行, 当然,为了并发地运行函数,必须使用特定的函数以及对象来管理各个线程. 从hello world 开始 让我们从一个经典的例子开始:一个打印"Hello World."的程序.一个非常简单的在单线程中运行的Hello, World 程序如下所示,当我们谈到多线程时,它可以作为一个基准, #include<iostream> i

Java并发编程学习笔记(二)——对象的共享

主要概念:可见性.重排序.失效数据.最低安全性.发布.逸出.线程封闭(Ad-hoc.栈封闭.ThreadLocal类).不变性.Final域.事实不可变对象. 1.在没有同步的情况下,编译器.处理器以及运行时等都可能对操作的执行顺序进行一些意想不到的调整.在缺乏足够同步的多线程程序中,要想对内存操作的执行顺序进行判断,几乎无法得出正确的结论. 2.在多线程中使用共享且可变的long和double等类型的变量是不安全的,除非用关键字volatile来声明它们,或者用锁来保护他们. 3.加锁的含义不

JAVA并发编程学习笔记------线程的三种创建方式

创建线程一般有如下几个方式: 1. 通过继承Thread类来创建一个线程: /** * 步骤1:定义一个继承Thread类的子类 * 步骤2:构造子类的一个对象 * 步骤3:启动线程: * */ public class ThreadTest{ public static void main(String[] args) { //构造子类对象 SubThread subThread = new SubThread(); //启动线程 subThread.start(); } } //定义继承Th

JAVA并发编程学习笔记------对象的可见性及发布逸出

一.非原子的64位操作: 当线程在没有同步的情况下读取变量时,可能会得到一个失效值,但至少这个值是由之前某个线程设置的值,而不是一个随机值,这种安全性保证被称为最低安全性.最低安全性适用于绝大多数变量,但存在一个例外:非volatile类型的64位数值变量(double,long),Java内存模型要求,变量的读取和写入操作都必须是原子操作,但对于非volatile型的long,double变量,JVM允许将64位的读操作或写操作分解为两个32位的操作,当读取一个非volatile类型的long