grinda.impl
Class BlockingOperationManager

java.lang.Object
  extended by java.lang.Thread
      extended by grinda.impl.AbstractSubscribeManager
          extended by grinda.impl.BlockingOperationManager
All Implemented Interfaces:
java.lang.Runnable

public class BlockingOperationManager
extends AbstractSubscribeManager

Handles tuples just inserted notifying eventually the clients that are blocked upon operations like take


Nested Class Summary
 
Nested classes/interfaces inherited from class grinda.impl.AbstractSubscribeManager
AbstractSubscribeManager.HandlingInfo
 
Nested classes/interfaces inherited from class java.lang.Thread
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler
 
Field Summary
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
BlockingOperationManager()
           
 
Method Summary
 void addListener(TupleSpaceOperation op, java.lang.String dst)
          Adds a listener for a blocking operation
 boolean handle(TupleSpaceResult r)
          Handles result coming from other peers
 void removeListener(TupleSpaceOperation op, java.lang.String dst)
          Removes a listener
 void setTupleSpaceSet(TupleSpaceSet s)
           
 
Methods inherited from class grinda.impl.AbstractSubscribeManager
enqueue, run, terminate
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

BlockingOperationManager

public BlockingOperationManager()
Method Detail

setTupleSpaceSet

public void setTupleSpaceSet(TupleSpaceSet s)

handle

public boolean handle(TupleSpaceResult r)
Handles result coming from other peers

Parameters:
r - TupleSpaceResult
Returns:
true

addListener

public void addListener(TupleSpaceOperation op,
                        java.lang.String dst)
Adds a listener for a blocking operation

Specified by:
addListener in class AbstractSubscribeManager
Parameters:
op - the operation
dst - url of the listener

removeListener

public void removeListener(TupleSpaceOperation op,
                           java.lang.String dst)
Description copied from class: AbstractSubscribeManager
Removes a listener

Specified by:
removeListener in class AbstractSubscribeManager
Parameters:
op - the operation template to listen to
dst - listener address


Copyright © 2006 Sirio Capizzi. All Rights Reserved.