jdk1.4 构建 java多线程,并发设计框架 (二)-白红宇

jdk1.4 构建 java多线程,并发设计框架 (二)

阅读量：2792 次

发布时间：2019-05-13

本文共 1496 字，大约阅读时间需要 4 分钟。

一个多线程并发排队

/**
 * 线程请求队列，用来处理多线程并发排队.
 * 实际用的是先进先出的堆栈 Queue,默认队大小为128
 * @author guishuanglin 2008-11-3
 * 
 */
publicclass ConcurrentQueue { 
    private Queue QUEUE;
    private int QUEUE_SIZE = 128;
    private String QUEUE_NAME = "Queue";
    
public ConcurrentQueue() { 
        QUEUE = new Queue();
        printQueueSize();
    }
public ConcurrentQueue(int size) { 
        QUEUE_SIZE = size;
        QUEUE = new Queue();
        printQueueSize();
    }
public ConcurrentQueue(int size,String name) { 
        QUEUE_SIZE = size;
        QUEUE_NAME = QUEUE_NAME+"["+name+"]";
        QUEUE = new Queue();
        printQueueSize();
    }
    /**
     * 入队
     * @param call
     */
publicsynchronizedvoid enQueue(Object call) { 
while (QUEUE.size() > QUEUE_SIZE) { 
try { 
                System.out.println(QUEUE_NAME+" wait enQueue....");
                wait();
            } catch (InterruptedException e) { 
                e.printStackTrace();
            }
        }
        QUEUE.add(call);
        notifyAll();
        //System.out.println("入队");
    }
    /**
     * 出队
     * @param call
     */
publicsynchronized Object deQueue() { 
        Object call;
while (QUEUE.isEmpty()) { 
try { 
                System.out.println(QUEUE_NAME+" wait deQueue....");
                wait();
            } catch (InterruptedException e) { 
                e.printStackTrace();
            }
        }
        call = QUEUE.poll();
        notifyAll();
        //System.out.println("出队");
        return call;
    }
    /**
     * 打印当前队大小
     * @date 2008-11-4
     */
publicint size(){ 
        return QUEUE.size();
        
    }
    /**
     * 清空队
     * @date 2008-11-4
     */
publicvoid clear(){ 
        QUEUE.clear();
    }
    /**
     * 测试队是否有元素
     * @date 2008-11-4
     */
publicboolean isEmpty(){ 
        return QUEUE.isEmpty();
    }
    /**
     * 打印当前队大小
     * @date 2008-11-4
     */
privatevoid printQueueSize(){ 
        System.out.println("Concurrent queue size: "+QUEUE_SIZE);
    }
}