// This Source Code is in the Public Domain per: http://unlicense.org
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();
    }
}