package org.litesoft.GWT.eventbus.server.nonpublic;

import org.litesoft.GWT.eventbus.client.nonpublic.*;

public class ProcessingManagerServerImpl implements IProcessingManager
{
    private int mThreads = 0;

    public synchronized void waitTillNoOthers()
    {
        while ( mThreads != 0 )
        {
            try
            {
                wait();
            }
            catch ( InterruptedException e )
            {
                // Whatever...
            }
        }
    }

    public synchronized boolean incThreadsAndIndicateIfWeAreFirst()
    {
        boolean rv = (mThreads == 0);
        mThreads++;
        return rv;
    }

    public synchronized void decThreads()
    {
        mThreads--;
        notifyAll();
    }
}