| 概述 实时线程池的这些特性，重点围绕在线程资源控制，优先级控制。 在通用的非实时系统中，Doug Lea的util.conconrrenct同步线程开发包定义了很优美的结构模型和提供了基本的线程池实现。util.conconrrenct相关的内容，请自行参考。 从非实时的角度来看，Doug Lea提供的线程池实现，已经很完善。但是对于实时系统中，他缺少主要的实时特性。所以我的想法是，在非实时线程池上进行扩展，使他具备实时特性。 非实时线程池中不用修改，就可以被实时线程池利用的功能有以下几点： 对非实时线程池不具备的实时特性，有以下几点： 针对在非实时线程池之上扩展实时线程池，我们现在来一一讨论。 请求缓存按照优先级排队 解决的方法，就是在等待运行的请求队列中，实现根据优先级排队的队列。当一个请求任务被放入队列中时，如果发现，在他之前，有低的优先级任务存在，那么，高优先级任务就会向前移动，直到他前面的优先级都没有他低为止。
Util.conconrrent同步工具包中，队列的抽象叫做Channel。并且提供了几种队列实现，但是其中没有排序队列，这就需要我们自己来实现PriorityChannel。实现代码请见参考。 有了优先级排序的队列，取代非实时线程池中的请求队列，就实现了请求缓存按照优先级排队。 指定任务的执行的线程优先级 用户：
线程池内部：
现在，需要把任务放入请求队列时的优先级纪录下来，任务在运行的时候，根据这个优先级，改变运行的优先级级别，任务运行完成后，再还原线程优先级。
这样，线程池就可以根据请求任务的线程优先级，执行请求任务了。 配置通道(Lane)的线程池 线程池通道设计的出发点是：在线程池中，分成许多小的线程池，这些小的线程池，都指定了相应的优先级，当一个请求到达的时候，按照请求的优先级，直接将请求交给对应的那个小的线程池中运行 看看下面的例子： 当有一个优先级为15的请求任务，要求被执行，就会根据优先级匹配，将这个任务交给Lane2(15)来运行。 如果有一个优先级为13的请求任务到达后，怎么处理呢？线程池会根据优先级最接近的原则，找到Lane2(15),然后取出一个就绪线程，将此线程优先级调整到请求任务要求的优先级，然后运行。 对于用户来说，用户看到得是这个大的线程池，内部的Lane对用户并不可见。当Lane2(15)中已经没有多余的线程了，而其他小的线程池中还有线程。这时用户的请求任务会被阻塞。为了优化线程池，允许线程借调行为。当当前Lane中没有多余线程可用，可以从比他优先级低的Lane中借取线程，升高借来的线程的优先级，运行请求任务。运行完成后，还原线程优先级，退还线程。当所有被他低的Lane中都没有可用线程，这时用户的请求任务才会被阻塞。 以上描述了带通道的线程池的行为方式。如果将这个线程池退化到只有一个Lane的时候，这个线程池就等价于不带Lane的线程池。所以，只要实现带通道的线程池，我们通过对Lane的设置，就可以得到带Lane的和不带Lane的线程池。实际上，我们也是这样做的。 将前面我们改造过的线程池，作为我们线程池中的Lane，再根据用户的请求任务，为请求任务匹配合适的Lane，再把任务交给具体的Lane运行，就可以了。 结束 对于上面的内容，希望大家能够交流和讨论。以资进步。 参考 orbas是开放源码的一个Java CORBA的实现，对RT-CORBA进行支持。本文描述的实时线程吃，包含在orbas源码中。 http://www.huihoo.org/orbas/index.html Doug Lea的util.conconrrenct同步线程开发包 Real-Time Java Expert Group http://www.rtj.org 基于Jrate的rtsj RT-ORB:ZEN http://www.zen.uci.edu/ |
