hackedteam/core-blackberry

//#preprocess

/* *************************************************
 * Copyright (c) 2010 - 2012
 * HT srl,   All rights reserved.
 * 
 * Project      : RCS, RCSBlackBerry
 * *************************************************/

package blackberry.utils;

import blackberry.Trigger;
import blackberry.debug.Debug;
import blackberry.debug.DebugLevel;

public class BlockingQueueTrigger {

    //#ifdef DEBUG
    private static Debug debug = new Debug("BQTrigger",
            DebugLevel.VERBOSE);
    //#endif
    
    private String name;

    public BlockingQueueTrigger(String name) {
        this.name = name;
        open();
    }

    /**
     * The Class ClosedException.
     */
    public static class ClosedException extends RuntimeException {

        /**
         * Instantiates a new closed exception.
         */
        ClosedException() {
            super("Queue closed.");
        }
    }

    private final Queue list = new VectorQueue();

    //private final boolean wait = false;

    private boolean closed = false;

    /**
     * Close.
     */
    public synchronized void close() {
        closed = true;
        notifyAll();
    }

    Object blockedLock = new Object();

    /**
     * Dequeue.
     * 
     * @return the object
     */
    private synchronized Trigger dequeue() {
        while (!closed && list.isEmpty()) {
            try {
                wait();
            } catch (final InterruptedException e) {

            }
        }
        if (list.isEmpty()) {
            return null;
        }
        return (Trigger) list.dequeue();
    }

    /**
     * Enqueue.
     * 
     * @param o
     *            the o
     */
    public synchronized void enqueue(final Trigger o) {
        if (closed) {
            throw new ClosedException();
        }
        if(!list.contains(o)){
            list.enqueue(o);
            notifyAll();
        }else{
            //#ifdef DEBUG
            debug.trace("enqueue, already present: " + o);
            //#endif
        }
        
    }

    /**
     * Checks if is empty.
     * 
     * @return true, if is empty
     */
    public synchronized boolean isEmpty() {
        return list.isEmpty();
    }

    /**
     * Open.
     */
    public synchronized void open() {
        closed = false;
    }

    public synchronized Trigger getTriggeredAction() {
        return dequeue();
    }

    public synchronized void unTriggerAll() {
        list.clear();
    }

    public synchronized void unTrigger(int actionId) {

        list.remove(new Trigger(actionId, null));
    }

    public void clear() {
        list.clear();
    }

    //#ifdef DEBUG
    public String toString() {
        return "Queue: " + name + " size: " + list.size();
    }
    //#endif
}