com.viaoa.remote

Class OARemoteThread

java.lang.Object

java.lang.Thread

com.viaoa.remote.OARemoteThread

All Implemented Interfaces:

Runnable

public class OARemoteThread
extends Thread

Thread that is used to process broadcast remote method calls. By default, any "ripple effect" messages caused by this thread are not sent since each client will do the same thing.

Author:

vvia

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
Object	Lock
long	msLastUsed
long	msStartNextThread
RequestInfo	requestInfo
boolean	startedNextThread
boolean	stopCalled
boolean	watingOnLock

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
OARemoteThread()
OARemoteThread(Runnable r)

Method Summary

Modifier and Type	Method and Description
void	addRunnable(Runnable r) By default, this will call r.run().
boolean	getAllowRunnable()
boolean	getSendMessages()
boolean	isWaitingOnLock()
void	reset() called before processing the next OASync message.
void	setAllowRunnable(boolean b) Flag to know if the addRunnable was overwritten to handle in another thread (pool).
void	setSendMessages(boolean b) Any OAsync changes (OAObject/Hub) that are made within an OARemoteThread will not be broadcast to other computers, since they will also be processing the same originating message.
void	setStartedNextThread(boolean b)
void	setWaitingOnLock(boolean b) Flag to know if this thread is waiting on a lock set by OATreadLocalDelegate.
boolean	startedNextThread()
void	startNextThread() Called once this thread has reached it's main "mark" for the method that it is running, so that a new thread can process the next message.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, 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, run, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

Lock

public final Object Lock

stopCalled

public volatile boolean stopCalled

requestInfo

public volatile RequestInfo requestInfo

startedNextThread

public volatile boolean startedNextThread

watingOnLock

public volatile boolean watingOnLock

msStartNextThread

public volatile long msStartNextThread

msLastUsed

public volatile long msLastUsed

Constructor Detail

OARemoteThread

public OARemoteThread()

OARemoteThread

public OARemoteThread(Runnable r)

Method Detail

setAllowRunnable

public void setAllowRunnable(boolean b)

Flag to know if the addRunnable was overwritten to handle in another thread (pool). Otherwise, calling addRunnable will call the run() method directly.

getAllowRunnable

public boolean getAllowRunnable()

addRunnable

public void addRunnable(Runnable r)

By default, this will call r.run(). This can be overwritten to have it ran in another way.

startNextThread

public void startNextThread()

Called once this thread has reached it's main "mark" for the method that it is running, so that a new thread can process the next message. note: this is overwritten to start a new thread

startedNextThread

public boolean startedNextThread()

setSendMessages

public void setSendMessages(boolean b)

Any OAsync changes (OAObject/Hub) that are made within an OARemoteThread will not be broadcast to other computers, since they will also be processing the same originating message. This can be set to true, so that any OASync changes will be sent out. This is useful when an event listener will only run on the server, and any sync changes will then be sent to others. False by default.

getSendMessages

public boolean getSendMessages()

setWaitingOnLock

public void setWaitingOnLock(boolean b)

Flag to know if this thread is waiting on a lock set by OATreadLocalDelegate.

Parameters:

b -

isWaitingOnLock

public boolean isWaitingOnLock()

setStartedNextThread

public void setStartedNextThread(boolean b)

reset

public void reset()

called before processing the next OASync message.