Examples of CondVar

EDU.oswego.cs.dl.util.concurrent.CondVar
oswego.edu/dl/classes/EDU/oswego/cs/dl/util/concurrent/intro.html"> Introduction to this package. ]
com.sun.corba.se.impl.orbutil.concurrent.CondVar
oswego.edu/dl/classes/EDU/oswego/cs/dl/util/concurrent/intro.html"> Introduction to this package. ]
org.jgroups.util.CondVar
Class that checks on a condition and - if condition doesn't match the expected result - waits until the result matches the expected result, or a timeout occurs. First version used WaitableBoolean from util.concurrent, but that class would not allow for timeouts. @author Bela Ban @version $Id: CondVar.java,v 1.3 2004/12/31 14:10:40 belaban Exp $

Examples of EDU.oswego.cs.dl.util.concurrent.CondVar

/*     */ 
/*     */   public CVBuffer(int cap)
/*     */   {
/*  16 */     this.array = new Object[cap];
/*  17 */     this.mutex = new Mutex();
/*  18 */     this.notFull = new CondVar(this.mutex);
/*  19 */     this.notEmpty = new CondVar(this.mutex);
/*     */   }

View Full Code Here

Examples of com.sun.corba.se.impl.orbutil.concurrent.CondVar


        invocationCount = 0;


        poaMutex = new ReentrantMutex( orb.poaConcurrencyDebugFlag ) ;


        adapterActivatorCV = new CondVar( poaMutex,
            orb.poaConcurrencyDebugFlag ) ;
        invokeCV           = new CondVar( poaMutex,
            orb.poaConcurrencyDebugFlag ) ;
        beingDestroyedCV   = new CondVar( poaMutex,
            orb.poaConcurrencyDebugFlag ) ;


        isDestroying = new ThreadLocal () {
            protected java.lang.Object initialValue() {
                return Boolean.FALSE;

View Full Code Here

Examples of com.sun.corba.se.impl.orbutil.concurrent.CondVar

        this.poa = poa ;
        etherealizer = new Thread[1] ;
        etherealizer[0] = null ;
        counter = new int[1] ;
        counter[0] = 0 ;
        wait = new CondVar( poa.poaMutex,
            ((ORB)poa.getORB()).poaConcurrencyDebugFlag ) ;
    }

View Full Code Here

Examples of com.sun.corba.se.impl.orbutil.concurrent.CondVar

        this.poa = poa ;
        etherealizer = new Thread[1] ;
        etherealizer[0] = null ;
        counter = new int[1] ;
        counter[0] = 0 ;
        wait = new CondVar( poa.poaMutex,
            ((ORB)poa.getORB()).poaConcurrencyDebugFlag ) ;
    }

View Full Code Here

Examples of com.sun.corba.se.impl.orbutil.concurrent.CondVar


        invocationCount = 0;


        poaMutex = new ReentrantMutex( orb.poaConcurrencyDebugFlag ) ;


        adapterActivatorCV = new CondVar( poaMutex,
            orb.poaConcurrencyDebugFlag ) ;
        invokeCV           = new CondVar( poaMutex,
            orb.poaConcurrencyDebugFlag ) ;
        beingDestroyedCV   = new CondVar( poaMutex,
            orb.poaConcurrencyDebugFlag ) ;


        isDestroying = new ThreadLocal () {
            protected java.lang.Object initialValue() {
                return Boolean.FALSE;

View Full Code Here

Examples of com.sun.corba.se.impl.orbutil.concurrent.CondVar

        this.poa = poa ;
        etherealizer = new Thread[1] ;
        etherealizer[0] = null ;
        counter = new int[1] ;
        counter[0] = 0 ;
        wait = new CondVar( poa.poaMutex,
            ((ORB)poa.getORB()).poaConcurrencyDebugFlag ) ;
    }

View Full Code Here

Examples of org.jgroups.util.CondVar

        cond.waitUntilWithTimeout(Boolean.TRUE,  2000);
    }


    public void testDoubleLocking() throws org.jgroups.TimeoutException {
        final Map m=new HashMap();
        final CondVar c=new CondVar("bla", Boolean.FALSE, m);


        new Thread() {
            public void run() {
                Util.sleep(1000);
                _setValue(m, c);

View Full Code Here

Examples of org.jgroups.util.CondVar

public class CondVarTest implements Condition {
    protected CondVar          cond;
    protected volatile boolean done=false; // our condition


    @BeforeMethod protected void setup() {
        cond=new CondVar();
        done=false;
    }

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.