org.jppf.jca.work
Class JcaResultProcessor

java.lang.Object
  org.jppf.jca.work.JcaResultProcessor

All Implemented Interfaces:

Runnable, Work

public class JcaResultProcessor
extends Object
implements Work

Instances of this class send tasks to a JPPF driver and collect the results.

Constructor Summary

JcaResultProcessor(JPPFJcaClientConnection connection, JPPFJob job)
Initialize this result processor with a specified list of tasks, data provider and result listener.

Method Summary

JPPFJob	getJob() Get all the data pertaining to the execution for this task.
void	release() Stop this result processor.
void	run() This method executes until all partial results have been received.

Methods inherited from class java.lang.Object

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

Constructor Detail

JcaResultProcessor

public JcaResultProcessor(JPPFJcaClientConnection connection,
                          JPPFJob job)

Initialize this result processor with a specified list of tasks, data provider and result listener.

Parameters:

connection - the client connection owning this results processor.

job - the execution processed by this task.

Method Detail

run

public void run()

This method executes until all partial results have been received.

Specified by:

run in interface Runnable

See Also:

Runnable.run()

getJob

public JPPFJob getJob()

Get all the data pertaining to the execution for this task.

Returns:

a JPPFJob instance.

release

public void release()

Stop this result processor.

Specified by:

release in interface Work

See Also:

Work.release()