Создание и управление критичными секциями в приложении

public class  Queue
{
    ArrayList data     ;
    int       max_size ;
    boolean   running  ;
 
    /**
     * Creates queue with maximum size.
     */
    public  Queue(int size)
    {
        running = true;
        data     = new ArrayList(size);
        max_size = size;
    }
    
    /**
     * Adds message to queue. Blocks if it is full.
     */
    public synchronized void push( Message msg)
    {
        while(data.size()==max_size)
        {
            try
            {
                wait();
            } catch(InterruptedException x)
            {
                //do nothing
            }
        }
        data.add(msg);
        notifyAll();
    }
 
    /**
     * Adds messages to queue. Blocks if it is full
     * and even one message could not be added. Otherwise
     * returns number of messages actually added.
     */
    public synchronized int push( Message msg[])
    {
        while(data.size()==max_size)
        {
            try
            {
                wait();
            } catch(InterruptedException x)
            {
                //do nothing
            }
        }
        int n=Math.min(msg.length, max_size-data.size());
        for(int i=0;i<n;i++)
            data.add(msg[i]);
        notifyAll();
        return n;
    }
    
    /**
     * Pop message from queue. Blocks if it is empty.
     */
    public synchronized  Message pop()
    { 
        if(!running)
            return null;
        while(data.isEmpty())
        {
            try
            {
                wait();
            } catch(InterruptedException x)
            {
                //do nothing
            }
            if(!running)
                return null;
        }
        
         Message res=( Message)data.remove(0);
        notifyAll();
        return res;
    }
 
    /**
     * Fetch 'max_size' elements from queue. If nothing 
     * availiable - blocks. If less that max_size availaibe,
     * return as much as it have.
     */
    public synchronized  Message[] pop(int max_size)
    { 
        if(!running)
            return null;
        while(data.isEmpty())
        {
            try
            {
                wait();
            } catch(InterruptedException x)
            {
                //do nothing
            }
            if(!running)
                return null;
        }
            
        int n=Math.min(max_size,data.size());
        Message[] res=new  Message[n];
        for(int i=0;i<n;i++)
            res[i]=( Message)data.remove(0);
        notifyAll();
        return res;
    }
    
    public synchronized int size()
    {
        return data.size();
    }
 
    public synchronized void stop()
    {
        running = false;
        notifyAll();
    }
 
};