com.viaoa.remote.multiplexer

Class OARemoteThread

java.lang.Object

java.lang.Thread

com.viaoa.remote.multiplexer.OARemoteThread

All Implemented Interfaces:

Runnable

public class OARemoteThread
extends Thread

Thread that is used to process all remote method calls.

Author:

vvia

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

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()

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

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()

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.