org.logicblaze.lingo.util.locks
Class ConditionClient

java.lang.Object
  extended by org.logicblaze.lingo.util.locks.ConditionClient
All Implemented Interfaces:
edu.emory.mathcs.backport.java.util.concurrent.locks.Condition

public class ConditionClient
extends java.lang.Object
implements edu.emory.mathcs.backport.java.util.concurrent.locks.Condition

Implements a client side proxy to a remote Condition

Version:
$Revision$

Constructor Summary
ConditionClient(ConditionServer server, ConditionListener listener, java.lang.String id, edu.emory.mathcs.backport.java.util.concurrent.locks.Lock lock)
           
 
Method Summary
 void await()
           
 boolean await(long timeout, edu.emory.mathcs.backport.java.util.concurrent.TimeUnit unit)
           
 void awaitUninterruptibly()
           
 boolean awaitUntil(java.util.Date arg0)
           
 long getTimeout()
           
 void onSignal()
           
 void onSignalAll()
           
 void setTimeout(long timeout)
          Sets the failover time where if a server side condition server goes down, signals are re-requested again.
 void signal()
           
 void signalAll()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ConditionClient

public ConditionClient(ConditionServer server,
                       ConditionListener listener,
                       java.lang.String id,
                       edu.emory.mathcs.backport.java.util.concurrent.locks.Lock lock)
Method Detail

await

public void await()
           throws java.lang.InterruptedException
Specified by:
await in interface edu.emory.mathcs.backport.java.util.concurrent.locks.Condition
Throws:
java.lang.InterruptedException

awaitUninterruptibly

public void awaitUninterruptibly()
Specified by:
awaitUninterruptibly in interface edu.emory.mathcs.backport.java.util.concurrent.locks.Condition

await

public boolean await(long timeout,
                     edu.emory.mathcs.backport.java.util.concurrent.TimeUnit unit)
              throws java.lang.InterruptedException
Specified by:
await in interface edu.emory.mathcs.backport.java.util.concurrent.locks.Condition
Throws:
java.lang.InterruptedException

awaitUntil

public boolean awaitUntil(java.util.Date arg0)
                   throws java.lang.InterruptedException
Specified by:
awaitUntil in interface edu.emory.mathcs.backport.java.util.concurrent.locks.Condition
Throws:
java.lang.InterruptedException

signal

public void signal()
Specified by:
signal in interface edu.emory.mathcs.backport.java.util.concurrent.locks.Condition

signalAll

public void signalAll()
Specified by:
signalAll in interface edu.emory.mathcs.backport.java.util.concurrent.locks.Condition

onSignal

public void onSignal()

onSignalAll

public void onSignalAll()

getTimeout

public long getTimeout()

setTimeout

public void setTimeout(long timeout)
Sets the failover time where if a server side condition server goes down, signals are re-requested again.



Copyright © 2009 LogicBlaze, Inc.. All Rights Reserved.