Public Member Functions
	TaskThread (TaskRequestQueue *queue)
bool	getDone ()
void	setDone (bool done)
void	run ()
int	cancel ()
Private Attributes
osg::ref_ptr< TaskRequestQueue >	_queue
osg::ref_ptr< TaskRequest >	_request
volatile bool	_done

Detailed Description

Definition at line 147 of file TaskService.

Constructor & Destructor Documentation

TaskThread::TaskThread ( TaskRequestQueue * queue )

Definition at line 168 of file TaskService.cpp.

                                                :
_queue( queue ),
_done( false )
{
    //nop
}

Member Function Documentation

int TaskThread::cancel ( )

Definition at line 221 of file TaskService.cpp.

{
    if ( isRunning() )
    {
        _done = true;  

        if (_request.valid())
        {
            _request->cancel();
        }

        while( isRunning() )
        {        
            OpenThreads::Thread::YieldCurrentThread();
        }
    }
    return 0;
}

bool osgEarth::TaskThread::getDone ( ) [inline]

Definition at line 150 of file TaskService.

{ return _done;}

void TaskThread::run ( )

Definition at line 176 of file TaskService.cpp.

{
    while( !_done )
    {
        _request = _queue->get();

        if ( _done )
            break;

        if (_request.valid())
        { 
            // discard a completed or canceled request:
            if ( _request->getState() != TaskRequest::STATE_PENDING )
            {
                _request->cancel();
            }

            else if ( !_request->wasCanceled() )
            {
                if ( _request->getProgressCallback() )
                    _request->getProgressCallback()->onStarted();

                _request->setState( TaskRequest::STATE_IN_PROGRESS );
                _request->run();

                //OE_INFO << LC << "Task \"" << _request->getName() << "\" runtime = " << _request->runTime() << " s." << std::endl;
            }
            else
            {
                //OE_INFO << LC << "Task \"" << _request->getName() << "\" was cancelled before it ran." << std::endl;
            }
            
            _request->setState( TaskRequest::STATE_COMPLETED );

            // signal the completion of a request.
            if ( _request->getProgressCallback() )
                _request->getProgressCallback()->onCompleted();

            // Release the request
            _request = 0;
        }
    }
}