Package tests

Class complete_farm_testWorker<T,U>

java.lang.Object

bbflow.defaultJob<T,U>

tests.complete_farm_testWorker<T,U>

Type Parameters:

T - Type of channels

All Implemented Interfaces:

Runnable

public class complete_farm_testWorker<T,U>
extends defaultJob<T,U>

workers runJob of the example farm

Field Summary

Fields

Modifier and Type	Field	Description
(package private) Integer	mysum

Fields inherited from class bbflow.defaultJob

combined, combined_side, CUSTOM_FUNCTION, id, in, INLINE, INLINE_MULTI, out, position, runType

Constructor Summary

Constructors

Constructor	Description
complete_farm_testWorker(int id)

Method Summary

Modifier and Type	Method	Description
void	runJob()	blank function that should be overwritten by class extending bbflow.defaultJob.

Methods inherited from class bbflow.defaultJob

addInputChannel, addOutputChannel, EOS, getInputChannel, getOutputChannel, init, preload, removeInputChannel, removeOutputChannel, run, runJob, runJobMulti, sendEOS, sendEOS, sendOut, sendOut, sendOutTo, sendOutTo, sendOutToAll, setId, uniqueJob, uniqueJob

Methods inherited from class java.lang.Object

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

Field Details

mysum

Integer mysum

Constructor Details

complete_farm_testWorker

public complete_farm_testWorker(int id)

Method Details

runJob

public void runJob()
            throws InterruptedException

Description copied from class: defaultJob

blank function that should be overwritten by class extending bbflow.defaultJob. Here main computation task is done once we're sure there's data in at least one of the input channels Lists 'in' and 'out' must be used manually and EOS() must be managed by the user.

Overrides:

runJob in class defaultJob<T,U>

Throws:

InterruptedException