com.hazelcast.executor.impl

Class RunnableAdapter<V>

java.lang.Object

com.hazelcast.executor.impl.RunnableAdapter<V>

Type Parameters:

V -

All Implemented Interfaces:

HazelcastInstanceAware, DataSerializable, IdentifiedDataSerializable, PartitionAware, Callable<V>

public final class RunnableAdapter<V>
extends Object
implements IdentifiedDataSerializable, Callable<V>, HazelcastInstanceAware, PartitionAware

An adapter that adapts a Runnable to become a Callable.

Constructor Summary

Constructors

Constructor and Description
RunnableAdapter()
RunnableAdapter(Runnable task)

Method Summary

Modifier and Type	Method and Description
V	call()
int	getClassId() Returns type identifier for this class.
int	getFactoryId() Returns DataSerializableFactory factory ID for this class.
Object	getPartitionKey() The key that will be used by Hazelcast to specify the partition.
Runnable	getRunnable()
void	readData(ObjectDataInput in) Reads fields from the input stream
void	setHazelcastInstance(HazelcastInstance hazelcastInstance) Gets the HazelcastInstance reference when submitting a Runnable/Callable using Hazelcast ExecutorService.
void	setRunnable(Runnable runnable)
String	toString()
void	writeData(ObjectDataOutput out) Writes object fields to output stream

Methods inherited from class java.lang.Object

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

Constructor Detail

RunnableAdapter

public RunnableAdapter()

RunnableAdapter

public RunnableAdapter(Runnable task)

Method Detail

getRunnable

public Runnable getRunnable()

setRunnable

public void setRunnable(Runnable runnable)

call

public V call()
       throws Exception

Specified by:

call in interface Callable<V>

Throws:

Exception

getPartitionKey

public Object getPartitionKey()

Description copied from interface: PartitionAware

The key that will be used by Hazelcast to specify the partition. You should give the same key for objects that you want to be in the same partition.

Specified by:

getPartitionKey in interface PartitionAware

Returns:

the key that specifies the partition

setHazelcastInstance

public void setHazelcastInstance(HazelcastInstance hazelcastInstance)

Description copied from interface: HazelcastInstanceAware

Gets the HazelcastInstance reference when submitting a Runnable/Callable using Hazelcast ExecutorService.

Specified by:

setHazelcastInstance in interface HazelcastInstanceAware

Parameters:

hazelcastInstance - the HazelcastInstance reference

writeData

public void writeData(ObjectDataOutput out)
               throws IOException

Description copied from interface: DataSerializable

Writes object fields to output stream

Specified by:

writeData in interface DataSerializable

Parameters:

out - output

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the output stream has been closed.

readData

public void readData(ObjectDataInput in)
              throws IOException

Description copied from interface: DataSerializable

Reads fields from the input stream

Specified by:

readData in interface DataSerializable

Parameters:

in - input

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the input stream has been closed.

getFactoryId

public int getFactoryId()

Description copied from interface: IdentifiedDataSerializable

Returns DataSerializableFactory factory ID for this class.

Specified by:

getFactoryId in interface IdentifiedDataSerializable

Returns:

factory ID

getClassId

public int getClassId()

Description copied from interface: IdentifiedDataSerializable

Returns type identifier for this class. It should be unique per DataSerializableFactory.

Specified by:

getClassId in interface IdentifiedDataSerializable

Returns:

type ID

toString

public String toString()

Overrides:

toString in class Object