ptolemy.distributed.client

Class ClientThread

java.lang.Object

java.lang.Thread

ptolemy.distributed.client.ClientThread

All Implemented Interfaces:

java.lang.Runnable

public class ClientThread
extends java.lang.Thread

Thread that manages the interaction with the remote service. It is required to allow commands to be issued to the remote services in parallel. This threads prevent the main thread of execution to be blocked by the remote calls to the remote services. A synchronization mechanism to issue and access commands is provided by ThreadSynchronizer.

Since:

Ptolemy II 5.1

Version:

$Id: ClientThread.java 70398 2014-10-22 23:44:32Z cxh $

Author:

Daniel Lazaro Cuadrado (kapokasa@kom.aau.dk)

See Also:

ThreadSynchronizer

Accepted Rating:

Red (cxh)

Proposed Rating:

Red (kapokasa)

Nested Class Summary

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

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
static int	EXIT Exit command.
static int	FIRE Fire command.
static int	INITIALIZE Initialize command.
static int	ITERATE Iterate command.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ClientThread(ThreadSynchronizer synchr, net.jini.core.lookup.ServiceItem serv) Construct a ClientThread with a given ThreadSynchronizer and a given service.

Method Summary

Modifier and Type	Method and Description
net.jini.core.lookup.ServiceItem	getService() Return the service that this ClientThread controls.
void	run() Runs the thread.
void	setIterationCount(int iterationC) Specify the number of times that the iteration command is to be performed.

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, 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

EXIT

public static final int EXIT

Exit command.

See Also:

Constant Field Values

INITIALIZE

public static final int INITIALIZE

Initialize command.

See Also:

Constant Field Values

FIRE

public static final int FIRE

Fire command.

See Also:

Constant Field Values

ITERATE

public static final int ITERATE

Iterate command.

See Also:

Constant Field Values

Constructor Detail

ClientThread

public ClientThread(ThreadSynchronizer synchr,
                    net.jini.core.lookup.ServiceItem serv)

Construct a ClientThread with a given ThreadSynchronizer and a given service.

Parameters:

synchr - A ThreadSynchronizer.

serv - The service corresponding to the remote service that the Client Thread represents.

Method Detail

getService

public net.jini.core.lookup.ServiceItem getService()

Return the service that this ClientThread controls.

Returns:

A ServiceItem corresponding to the service this Client Thread is managing remotely.

run

public void run()

Runs the thread. The thread blocks until it gets a command. When a command is fetched, the service performs remotely the method corresponding to the given command. Once the task is performed, the thread is set to ready in the synchronizer. This is performed until de command is exit.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

setIterationCount

public void setIterationCount(int iterationC)

Specify the number of times that the iteration command is to be performed. We assume that this will be set correctly before iterate is called.

Parameters:

iterationC - Number of times the iteration has to be performed.