.NET4.0线程池的Cooperative Cancellation模式

刚装了VS2010RC版,体验一下.NET4.0线程池新增的Cooperative Cancellation模式。

用过.NET线程池的人都知道,一旦把要执行的代码交给线程池去执行后,我们 基本上就失去了代码在运行中的控制能力。比如,我们想在某个时刻取消这段代 码的执行,就得另想一个办法。随着.NET4.0到来,这个问题得到了解 决。.NET4.0引入了一种新的设计模式---合作取消模式(Cooperative Cancellation)。

.NET4.0的System.Threading命名空间下新增了两个成员,一个是 CancellationTokenSource类,一个是CancellationToken结构。 CancellationTokenSource类的主要成员如下:

public sealed class CancellationTokenSource : IDisposable  {
public CancellationTokenSource();
public void Dispose();
public Boolean IsCancellationRequested { get; }
public CancellationToken Token { get; }//CancellationToken结构
public void Cancel();
public void Cancel(Boolean throwOnFirstException);
}

CancellationToken结构代码大致如下:

 public struct CancellationToken
     { 
         public Boolean IsCancellationRequested { get;  }
         public void ThrowIfCancellationRequested();
         // 当CancellationTokenSource取消时使用的信号量
         public WaitHandle WaitHandle { get; }
         public static CancellationToken None { get; }
         public Boolean CanBeCanceled { get; }
         public CancellationTokenRegistration Register (Action<Object> callback, Object state, Boolean  useSynchronizationContext);
     }

使用代码如下:

using System;
using System.Threading;
namespace CooperativeCancellation
{
     class Program
     {
         static void Main(string[] args)
         {
             CancellationTokenSource cts = new  CancellationTokenSource();
             ThreadPool.QueueUserWorkItem(o =>  ExecuteInThreadPool(cts.Token));
             Console.WriteLine("Press <Enter> to  cancel the operation.");
             Console.ReadLine();
             cts.Cancel();
             Console.ReadLine();
         }
         static void ExecuteInThreadPool(CancellationToken  token)
         {
             Console.WriteLine("Enter in  ThreadPool.");
             while (!token.IsCancellationRequested)
             {
                 Console.Write(" .");
                 Thread.Sleep(1000);
             }
             Console.WriteLine("Operation was be  cancel.");
         }
     }
}

代码简单,我在这里就不多说了。总之,有了Cooperative Cancellation模式 后,我们对.NET线程池中的代码的执行有了更大的控制力度,真是个不错的功能 。

时间: 2024-10-29 16:24:52

.NET4.0线程池的Cooperative Cancellation模式的相关文章

Java线程池框架核心代码分析

前言 多线程编程中,为每个任务分配一个线程是不现实的,线程创建的开销和资源消耗都是很高的.线程池应运而生,成为我们管理线程的利器.Java 通过Executor接口,提供了一种标准的方法将任务的提交过程和执行过程解耦开来,并用Runnable表示任务. 下面,我们来分析一下 Java 线程池框架的实现ThreadPoolExecutor. 下面的分析基于JDK1.7 生命周期 ThreadPoolExecutor中,使用CAPACITY的高3位来表示运行状态,分别是: RUNNING:接收新任务

Java线程池框架核心代码解析_java

前言多线程编程中,为每个任务分配一个线程是不现实的,线程创建的开销和资源消耗都是很高的.线程池应运而生,成为我们管理线程的利器.Java 通过Executor接口,提供了一种标准的方法将任务的提交过程和执行过程解耦开来,并用Runnable表示任务. 下面,我们来分析一下 Java 线程池框架的实现ThreadPoolExecutor. 下面的分析基于JDK1.7 生命周期ThreadPoolExecutor中,使用CAPACITY的高3位来表示运行状态,分别是:  1.RUNNING:接收新任

论Java Web应用中调优线程池的重要性_java

不论你是否关注,Java Web应用都或多或少的使用了线程池来处理请求.线程池的实现细节可能会被忽视,但是有关于线程池的使用和调优迟早是需要了解的.本文主要介绍Java线程池的使用和如何正确的配置线程池. 单线程 我们先从基础开始.无论使用哪种应用服务器或者框架(如Tomcat.Jetty等),他们都有类似的基础实现.Web服务的基础是套接字(socket),套接字负责监听端口,等待TCP连接,并接受TCP连接.一旦TCP连接被接受,即可从新创建的TCP连接中读取和发送数据. 为了能够理解上述流

5天不再惧怕多线程——第五天 线程池

说到多线程,不可不说线程池,C#中关于池的概念很多,今天来整理下ThreadPool的使用. 是的,如果你很懒,如果你的执行任务比较短,如果你不想对线程做更精细的控制,那么把这些繁琐的东西丢给线程池吧. 一:ThreadPool 好了,下面看看TheadPool下有哪些常用的方法. 1:GetMaxThreads,GetMinThreads 首先我们肯定好奇线程池到底给我们如何控制线程数,下面就具体的看一看. class Program { static void Main(string[] a

Java并发编程:线程池的使用

以下是本文的目录大纲: 一.Java中的ThreadPoolExecutor类 二.深入剖析线程池实现原理 三.使用示例 四.如何合理配置线程池的大小 若有不正之处请多多谅解,并欢迎批评指正. 请尊重作者劳动成果,转载请标明原文链接: 一.Java中的ThreadPoolExecutor类 java.uitl.concurrent.ThreadPoolExecutor类是线程池中最核心的一个类,因此如果要透彻地了解Java中的线程池,必须先了解这个类.下面我们来看一下ThreadPoolExec

Java并发编程:线程池的使用(转)

Java并发编程:线程池的使用 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实现起来非常简便,但是就会有一个问题: 如果并发的线程数量很多,并且每个线程都是执行一个时间很短的任务就结束了,这样频繁创建线程就会大大降低系统的效率,因为频繁创建线程和销毁线程需要时间. 那么有没有一种办法使得线程可以复用,就是执行完一个任务,并不被销毁,而是可以继续执行其他的任务? 在Java中可以通过线程池来达到这样的效果.今天我们就来详细讲解一下Java的线程池,首先我们从最核心的ThreadPool

C语言实现支持动态拓展和销毁的线程池_C 语言

本文实例介绍了C 语言实现线程池,支持动态拓展和销毁,分享给大家供大家参考,具体内容如下 实现功能 1.初始化指定个数的线程 2.使用链表来管理任务队列 3.支持拓展动态线程 4.如果闲置线程过多,动态销毁部分线程 #include <stdio.h> #include <pthread.h> #include <stdlib.h> #include <signal.h> /*线程的任务队列由,函数和参数组成,任务由链表来进行管理*/ typedef str

深入解析C++编程中线程池的使用_C 语言

为什么需要线程池目前的大多数网络服务器,包括Web服务器.Email服务器以及数据库服务器等都具有一个共同点,就是单位时间内必须处理数目巨大的连接请求,但处理时间却相对较短. 传 统多线程方案中我们采用的服务器模型则是一旦接受到请求之后,即创建一个新的线程,由该线程执行任务.任务执行完毕后,线程退出,这就是是"即时创建,即 时销毁"的策略.尽管与创建进程相比,创建线程的时间已经大大的缩短,但是如果提交给线程的任务是执行时间较短,而且执行次数极其频繁,那么服务器将处于 不停的创建线程,销

J2SE5.0中的线程缓冲 ---- 线程池

一.前言 用Java编写多线程程序已经是一个非常简单的事了,不过与其它多线程系统相比,一些高级特性在Java中仍然不具备,然而在J2SE5.0中这一切将会改变.J2SE5.0增加大量的线程相关类使得编写多线程程序更加容易! 二.线程池-Thread Pools 线程库的基本思想简单的讲就是,一个线程库中拥有一定数量的线程,当有任务要执行时,就从线程库中找一个空闲的线程来执行这个任务,任务执行完后,该线程返回线程库等待下一个任务;如果线程库中没有空闲的线程来执行该任务,这时该任务将要等待直到有一个