InputHandler subclass than can be plugged into SingleChannel to get multi-threaded computations. More...
#include <Channels/InputHandlerThreaded.H>
Classes | |
struct | Job |
Represents a pending SingleChannel input job. More... | |
Public Member Functions | |
InputHandlerThreaded () | |
Constructor. | |
virtual | ~InputHandlerThreaded () |
Virtual destructor ensures proper destruction of derived classes. | |
virtual void | handleInput (SingleChannel &chan, const Image< float > &bwimg, const SimTime &t, const Image< byte > &clipMask, const rutz::shared_ptr< PyramidCache< float > > &cache) |
Send the input image off to the processing node. | |
virtual void | waitForOutput (SingleChannel &chan) |
Have we received the results from our processing node yet? |
InputHandler subclass than can be plugged into SingleChannel to get multi-threaded computations.
Definition at line 45 of file InputHandlerThreaded.H.
InputHandlerThreaded::InputHandlerThreaded | ( | ) |
Constructor.
Definition at line 110 of file InputHandlerThreaded.C.
InputHandlerThreaded::~InputHandlerThreaded | ( | ) | [virtual] |
Virtual destructor ensures proper destruction of derived classes.
Definition at line 116 of file InputHandlerThreaded.C.
void InputHandlerThreaded::handleInput | ( | SingleChannel & | chan, | |
const Image< float > & | bwimg, | |||
const SimTime & | t, | |||
const Image< byte > & | clipMask, | |||
const rutz::shared_ptr< PyramidCache< float > > & | cache | |||
) | [virtual] |
Send the input image off to the processing node.
Implements InputHandler.
Definition at line 120 of file InputHandlerThreaded.C.
References ASSERT, JobServer::enqueueJob(), rutz::shared_ptr< T >::is_valid(), and rutz::make_shared().
void InputHandlerThreaded::waitForOutput | ( | SingleChannel & | chan | ) | [virtual] |
Have we received the results from our processing node yet?
Implements InputHandler.
Definition at line 132 of file InputHandlerThreaded.C.
References ModelComponent::descriptiveName(), rutz::shared_ptr< T >::is_valid(), and rutz::shared_ptr< T >::reset().