2011年计算机等考二级JAVA学习精华整理(48)

　　根据不同的需要BlockingQueue有4种具体实现：

　　ArrayBlockingQueue：规定大小的BlockingQueue，其构造函数必须带一个int参数来指明其大小。其所含的对象是以FIFO(先入先出)顺序排序的。

　　LinkedBlockingQueue：大小不定的BlockingQueue，若其构造函数带一个规定大小的参数，生成的BlockingQueue有大小限制，若不带大小参数，所生成的BlockingQueue的大小由Integer.MAX_VALUE来决定。其所含的对象是以FIFO(先入先出)顺序排序的。LinkedBlockingQueue和ArrayBlockingQueue比较起来，它们背后所用的数据结构不一样，导致LinkedBlockingQueue的数据吞吐量要大于ArrayBlockingQueue，但在线程数量很大时其性能的可预见性低于ArrayBlockingQueue。

　　PriorityBlockingQueue：类似于LinkedBlockingQueue，但其所含对象的排序不是FIFO，而是依据对象的自然排序顺序或者是构造函数所带的Comparator决定的顺序。

　　SynchronousQueue：特殊的BlockingQueue，对其的操作必须是放和取交替完成的。

　　下面是用BlockingQueue来实现Producer和Consumer的例子：

　　public class BlockingQueueTest {

　　static BlockingQueue basket;

　　public BlockingQueueTest() {

　　//定义了一个大小为2的BlockingQueue，也可根据需要用其他的具体类

　　basket = new ArrayBlockingQueue(2);

　　}

　　class Producor implements Runnable {

　　public void run() {

　　while(true){

　　try {

　　//放入一个对象，若basket满了，等到basket有位置

　　basket.put("An apple");

　　} catch (InterruptedException ex) {

　　ex.printStackTrace();

　　}

　　}

　　}

　　}

　　class Consumer implements Runnable {

　　public void run() {

　　while(true){

　　try {

　　//取出一个对象，若basket为空，等到basket有东西为止

　　String result = basket.take();

　　} catch (InterruptedException ex) {

　　ex.printStackTrace();

　　}

　　}

　　}

　　}

　　public void execute(){

　　for(int i=0; i<10; i++){

　　new Thread(new Producor()).start();

　　new Thread(new Consumer()).start();

　　}

　　}

　　public static void main(String[] args){

　　BlockingQueueTest test = new BlockingQueueTest();

　　test.execute();

　　}

　　}

　　7：Atomics 原子级变量

　　原子量级的变量，主要的类有AtomicBoolean, AtomicInteger, AotmicIntegerArray, AtomicLong, AtomicLongArray, AtomicReference ……。这些原子量级的变量主要提供两个方法：

　　compareAndSet(expectedValue, newValue): 比较当前的值是否等于expectedValue,若等于把当前值改成newValue，并返回true。若不等，返回false。

　　getAndSet(newValue): 把当前值改为newValue，并返回改变前的值。

　　这些原子级变量利用了现代处理器(CPU)的硬件支持可把两步操作合为一步的功能，避免了不必要的锁定，提高了程序的运行效率。

　　8：Concurrent Collections 共点聚集

　　在Java的聚集框架里可以调用Collections.synchronizeCollection(aCollection)将普通聚集改变成同步聚集，使之可用于多线程的环境下。 但同步聚集在一个时刻只允许一个线程访问它，其它想同时访问它的线程会被阻断，导致程序运行效率不高。Java 5.0里提供了几个共点聚集类，它们把以前需要几步才能完成的操作合成一个原子量级的操作，这样就可让多个线程同时对聚集进行操作，避免了锁定，从而提高了程序的运行效率。Java 5.0目前提供的共点聚集类有：ConcurrentHashMap, ConcurrentLinkedQueue, CopyOnWriteArrayList和CopyOnWriteArraySet.

　　　　　　　2010年9月计算机等级考试成绩查询时间汇总

 　　　　　　 2011计算机等级考试二级JAVA学习精华汇总