原文链接

CCR第三个重要的组成部分是任务调度：当有接收器的port上有消息到达时如何生成任务和在有多个执行资源的机器上进行负载均衡。在CCR中有三个实现或者抽象任务调度的重要类。

• ITask接口和它的实现：Task类和IterativeTask类。只有实现了ITask接口的类型才能被CCR调度。仲裁器也实现了ITask接口，所以他们可以被调度和正确的激活。
• DispatcherQueue类型。DispatcherQueue是FIFO的任务队列，它可以用CLR线程池来调度任务（非常少见）或者用一个CCR Dispatcher的实例来调度。
• Dispatcher类型。Dispatcher管理操作系统线程和对从一个或者多个DispatcherQueue中取出的任务进行负载均衡。

例16.

var dispatcher = new Dispatcher(
    0, // zero means use one thread per CPU, or 2 if only one CPU present
    "sample dispatcher" // friendly name assgined to OS threads
    );

var taskQueue 

例16展示了如何创建Dispatcher和DispatcherQueue实例并用于调度任务。下面是对这个例子的每一步的描述：

1. 使用0作为线程数量参数创建一个Dispatcher，这使得CCR根据机器的CPU数量自己选择一个线程数量。每个CPU上的线程数量是根据Dispatcher的静态属性ThreadsPerCpu确定的，默认为每个CPU一个线程。
2. 使用步骤1中创建的Dispatcher作为参数创建一个DispatcherQueue实例，这一步将DispatcherQueue附加到Dispatcher上。
3. 创建一个Port<int>类型的实例。我们将用这个port来投递元素和附加带有delegate点接收器。
4. 使用下列参数调用Arbiter.Activate方法。a.面创建的DispatcherQueue实例;b.用前面创建的port和一个回调作为参数新创建的一个接收者仲裁器，回调将会在有元素被投递到port时被调用。
5. 一个int类型的元素被投递到port。

当一个元素被投递到附加了接收器的port，port的实现中将会发生如下操作：

1. 为投递进来的元素创建一个容器。容器的类型（IPortElement）允许CCR在不知道元素类型的情况下将元素排队并将元素赋值给Task实例。
2. 容器被放入队列。
3. 如果接收器列表不是null，并且其中有一个以上的接收器，port对象将会调用ReceiverTask.Evaluate方法来让接收器和它里面的仲裁器层次检测元素是否可以被使用，在这个例子中，Evaluate方法将会返回true，并使用收到的元素和用户的delegate作为参数创建一个Task<int>实例。
4. port使用调用Evaluate方法返回的Task对象作为参数调用taskQueue.Enqueue，注意，当一个接收器是第一次被激活，它会被关联到由Arbiter.Activate方法提供的DispatcherQueue实例。

当上面的4步完成之后，生成的Task对象现在已经被调度逻辑分发(dealt)。

例17

// directly enqueue a task with an inlined method plus a parameter
taskQueue.Enqueue(
    new Task<int>(5, item => Console.WriteLine(item))
    );

上面这个例子我们展示了一个与例16中的调度功能等价的代码，但是不需要向port中投递任何元素。当数据已经准备好而且代码可以立即来处理它时，直接创建Task的实例很有用。CCR在Port.Post被调用时会调用接收器来创建Task实例，创建操作和例子中的类似。

一旦一个元素被放入DispatcherQueue，将会做如下操作：

1. DispatcherQueue向它所属的Dispatcher发信号，告诉Dispatcher一个新的任务可以被执行了。
2. Dispatcher通知一个或者多个TaskExecutionWorker类型对象。每个TaskExecutionWorker对象管理一个操作系统线程。它将线程设置到一种高效的休眠状态，直到Dispatcher发出信号通知有元素可以被调度时。
3. TaskExecutionWorker对象调用DispatcherQueue.Test方法从队列中获取一个任务。如果可用的任务，TaskExecutionWorker对象调用ITask.Execute。
4. Task.Execute方法调用关联在task对象上的delegate，并将一个或者多个关联在task上的参数传递进去。在我们的例子中一个值为5的单参数被传递给delegate，delegate将参数输出到控制台。

速度控制

CCR DispatcherQueue的实现允许根据一些预先定义的规则对任务执行进行速度控制。任务速度控制是CCR的关键功能，它使得程序可以把管理大队列的复杂性交给CCR调度器，从而优雅的处理大量的消息负载。速度控制策略是在DispatcherQueue创建时指定的。因为每个协调原语可以使用不同的DispatcherQueue，所以程序员可以给不同的处理器（handler）应用不同的策略。

任务执行策略枚举

例26.

void ThrottlingExample()
{
    int maximumDepth = 10;
    Dispatcher dispatcher = new Dispatcher(0, "throttling example");
    DispatcherQueue depthThrottledQueue = new DispatcherQueue("ConstrainQueueDepthDiscard",
          dispatcher,
          TaskExecutionPolicy.ConstrainQueueDepthDiscardTasks,
          maximumDepth);

    Port

例26中，我们创建了一个Dispatcher实例和一个DispatcherQueue实例，但是我们指定了一个ConstrainQueueDepthDiscardTasks任务执行策略,ConstrainQueueDepthDiscardTasks是一个策略选项。然后我们附加了一个持久化的接收器，并且以最快的速度投递了100万个元素。如果没有指定策略，一百万个任务将会被调度到机器的所有CPU上，并且dispatcher queue的深度将会增长到非常大。当指定了策略的时候，CCR将会抛弃最旧的任务，而且只会保持最新的10个任务执行。这种情况在只有最新的消息是有效的情况下是很有用的（通知、定时器等等）。

重要：depthThrottledQueue实例是提供给Arbiter.Activate方法将这个队列和指定的策略关联在一起，并将队列和用户在收到元素时生成Task对象的一个单元素接收器关联在一起。

策略场景